30 references to Complete
Aspire.Dashboard.Components.Tests (1)
Pages\ConsoleLogsTests.cs (1)
82consoleLogsChannel.Writer.Complete();
Aspire.Dashboard.Tests (3)
ChannelExtensionsTests.cs (3)
85resultChannel.Writer.Complete(); 102channel.Writer.Complete(); 129resultChannel.Writer.Complete();
Aspire.Hosting (1)
ApplicationModel\ResourceLoggerService.cs (1)
187channel.Writer.Complete();
Aspire.Hosting.Tests (3)
Dcp\ApplicationExecutorTests.cs (1)
637logStreamPipesChannel.Writer.Complete();
Utils\Grpc\TestAsyncStreamReader.cs (1)
32_channel.Writer.Complete();
Utils\Grpc\TestServerStreamWriter.cs (1)
25_channel.Writer.Complete();
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.CodeStyle (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();
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)
163channel.Writer.Complete();
TestDiscoveryWorker (1)
Program.cs (1)
138_channel.Writer.Complete();