46 references to Complete
Aspire.Cli.Tests (1)
Commands\LogsCommandTests.cs (1)
1481logLines.Writer.Complete();
Aspire.Dashboard.Components.Tests (5)
Pages\ConsoleLogsTests.cs (4)
134consoleLogsChannel.Writer.Complete(); 168subscribedResourceNamesChannel.Writer.Complete(); 550consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!")); 601consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!"));
tests\Shared\TestDashboardTelemetrySender.cs (1)
28ContextChannel.Writer.Complete();
Aspire.Dashboard.Tests (8)
ChannelExtensionsTests.cs (3)
124resultChannel.Writer.Complete(); 141channel.Writer.Complete(); 168resultChannel.Writer.Complete();
ResourceOutgoingPeerResolverTests.cs (4)
333resultChannel.Writer.Complete(); 365sourceChannel.Writer.Complete(); 391sourceChannel.Writer.Complete(); 417sourceChannel.Writer.Complete();
tests\Shared\TestDashboardTelemetrySender.cs (1)
28ContextChannel.Writer.Complete();
Aspire.Hosting (3)
ApplicationModel\ResourceLoggerService.cs (2)
266channel.Writer.Complete(); 334channel.Writer.Complete();
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
1685completeWriterTask = Task.WhenAll(tasks).ContinueWith(_ => channel.Writer.Complete(), CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
Aspire.Hosting.Tests (11)
Dcp\DcpExecutorTests.cs (1)
3354logStreamPipesChannel.Writer.Complete();
ResourceCommandServiceTests.cs (2)
155commandResourcesChannel.Writer.Complete(); 193commandResourcesChannel.Writer.Complete();
ResourceLoggerServiceTests.cs (3)
265consoleLogsChannel0.Writer.Complete(); 269consoleLogsChannel1.Writer.Complete(); 484consoleLogsChannel.Writer.Complete();
VersionChecking\VersionCheckServiceTests.cs (5)
99interactionService.Interactions.Writer.Complete(); 183interactionService.Interactions.Writer.Complete(); 214interactionService.Interactions.Writer.Complete(); 243interactionService.Interactions.Writer.Complete(); 284interactionService.Interactions.Writer.Complete();
Aspire.Hosting.TestUtilities (2)
Utils\Grpc\TestAsyncStreamReader.cs (1)
32_channel.Writer.Complete(ex);
Utils\Grpc\TestServerStreamWriter.cs (1)
25_channel.Writer.Complete(ex);
dotnet (1)
Commands\Test\MTP\TestApplicationActionQueue.cs (1)
67_channel.Writer.Complete();
dotnet-aot (1)
src\sdk\src\Cli\dotnet\Commands\Test\MTP\TestApplicationActionQueue.cs (1)
67_channel.Writer.Complete();
GenerateDocumentationAndConfigFiles (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
75static (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.CodeAnalysis.Analyzers (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.AnalyzerUtilities (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.CodeStyle (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.ResxSourceGenerator (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.Workspaces (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.DotNet.HotReload.Utils.Generator (1)
Util\FSWGen.cs (1)
46_channel?.Writer.Complete();
Microsoft.ML.Sweeper (1)
AsyncSweeper.cs (1)
224_paramChannel.Writer.Complete();
Roslyn.Diagnostics.Analyzers (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Stress.ApiService (2)
ProducerConsumer.cs (1)
65_channel.Writer.Complete();
Program.cs (1)
310channel.Writer.Complete();
System.IO.FileSystem.Watcher (1)
System\IO\FileSystemWatcher.Linux.cs (1)
1095_eventQueue.Writer.Complete();