55 references to Complete
Aspire.Dashboard.Components.Tests (5)
Pages\ConsoleLogsTests.cs (4)
138consoleLogsChannel.Writer.Complete(); 172subscribedResourceNamesChannel.Writer.Complete(); 268consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!")); 319consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!"));
tests\Shared\TestDashboardTelemetrySender.cs (1)
28ContextChannel.Writer.Complete();
Aspire.Dashboard.Tests (5)
ChannelExtensionsTests.cs (3)
85resultChannel.Writer.Complete(); 102channel.Writer.Complete(); 129resultChannel.Writer.Complete();
ResourceOutgoingPeerResolverTests.cs (1)
170resultChannel.Writer.Complete();
tests\Shared\TestDashboardTelemetrySender.cs (1)
28ContextChannel.Writer.Complete();
Aspire.Hosting (2)
ApplicationModel\ResourceLoggerService.cs (1)
314channel.Writer.Complete();
Backchannel\BackchannelLoggerProvider.cs (1)
58_channel.Writer.Complete();
Aspire.Hosting.Tests (9)
Dcp\DcpExecutorTests.cs (1)
760logStreamPipesChannel.Writer.Complete();
ResourceCommandServiceTests.cs (1)
77commandResourcesChannel.Writer.Complete();
ResourceLoggerServiceTests.cs (2)
264consoleLogsChannel0.Writer.Complete(); 268consoleLogsChannel1.Writer.Complete();
Utils\Grpc\TestAsyncStreamReader.cs (1)
32_channel.Writer.Complete(ex);
Utils\Grpc\TestServerStreamWriter.cs (1)
25_channel.Writer.Complete(ex);
VersionChecking\VersionCheckServiceTests.cs (3)
92interactionService.Interactions.Writer.Complete(); 152interactionService.Interactions.Writer.Complete(); 181interactionService.Interactions.Writer.Complete();
GenerateDocumentationAndConfigFiles (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Metrics (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Metrics.Legacy (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.AspNetCore.Server.Kestrel.Core (2)
Internal\WebTransport\WebTransportSession.cs (2)
88_pendingStreams.Writer.Complete(); 119_pendingStreams.Writer.Complete();
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (2)
HubConnectionTests.cs (2)
806channelWriter.Writer.Complete(); 2951_taskQueue.Writer.Complete();
Microsoft.AspNetCore.SignalR.Client.Tests (1)
HubConnectionTests.cs (1)
592channel.Writer.Complete(new Exception("error from client"));
Microsoft.AspNetCore.SignalR.Microbenchmarks (4)
DefaultHubDispatcherBenchmark.cs (4)
137channel.Writer.Complete(); 145channel.Writer.Complete(); 153channel.Writer.Complete(); 168channel.Writer.Complete();
Microsoft.AspNetCore.SignalR.Tests (4)
HubConnectionHandlerTestUtils\Hubs.cs (2)
302output.Complete(); 712channel.Writer.Complete();
NativeAotTests.cs (2)
84channel.Writer.Complete(); 116channelShorts.Writer.Complete();
Microsoft.CodeAnalysis.Analyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.AnalyzerUtilities (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.BannedApiAnalyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.CodeStyle (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.PublicApiAnalyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.ResxSourceGenerator (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.Workspaces (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.ML.Sweeper (1)
AsyncSweeper.cs (1)
224_paramChannel.Writer.Complete();
Roslyn.Diagnostics.Analyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
SignalR.Client.FunctionalTestApp (2)
TestHub.cs (2)
66channel.Writer.Complete(); 101channel.Writer.Complete();
SignalRSamples (1)
Hubs\UploadHub.cs (1)
77output.Writer.Complete();
Stress.ApiService (2)
ProducerConsumer.cs (1)
65_channel.Writer.Complete();
Program.cs (1)
195channel.Writer.Complete();
Test.Utilities (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
TestDiscoveryWorker (1)
Program.cs (1)
141_channel.Writer.Complete();
Text.Analyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),