42 references to Complete
Aspire.Dashboard.Components.Tests (5)
Pages\ConsoleLogsTests.cs (4)
132consoleLogsChannel.Writer.Complete(); 166subscribedResourceNamesChannel.Writer.Complete(); 417consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!")); 468consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!"));
tests\Shared\TestDashboardTelemetrySender.cs (1)
28ContextChannel.Writer.Complete();
Aspire.Dashboard.Tests (8)
ChannelExtensionsTests.cs (3)
85resultChannel.Writer.Complete(); 102channel.Writer.Complete(); 129resultChannel.Writer.Complete();
Mcp\AspireResourceMcpToolsTests.cs (1)
134logsChannel.Writer.Complete();
Model\AIAssistant\AIContextProviderTests.cs (1)
114changeChannel.Writer.Complete();
Model\AIAssistant\AssistantChatDataContextTests.cs (1)
115consoleLogsChannel.Writer.Complete();
ResourceOutgoingPeerResolverTests.cs (1)
176resultChannel.Writer.Complete();
tests\Shared\TestDashboardTelemetrySender.cs (1)
28ContextChannel.Writer.Complete();
Aspire.Hosting (3)
ApplicationModel\ResourceLoggerService.cs (2)
263channel.Writer.Complete(); 331channel.Writer.Complete();
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
736_ = Task.WhenAll(tasks).ContinueWith(_ => channel.Writer.Complete(), CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
Aspire.Hosting.Tests (11)
Dcp\DcpExecutorTests.cs (1)
874logStreamPipesChannel.Writer.Complete();
ResourceCommandServiceTests.cs (2)
99commandResourcesChannel.Writer.Complete(); 137commandResourcesChannel.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 (4)
98interactionService.Interactions.Writer.Complete(); 182interactionService.Interactions.Writer.Complete(); 213interactionService.Interactions.Writer.Complete(); 242interactionService.Interactions.Writer.Complete();
dotnet (1)
Commands\Test\MTP\TestApplicationActionQueue.cs (1)
42_channel.Writer.Complete();
GenerateDocumentationAndConfigFiles (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
81static (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)
81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.AnalyzerUtilities (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.CodeStyle (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.ResxSourceGenerator (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.Workspaces (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
81static (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)
81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Stress.ApiService (2)
ProducerConsumer.cs (1)
65_channel.Writer.Complete();
Program.cs (1)
266channel.Writer.Complete();
System.IO.FileSystem.Watcher (1)
System\IO\FileSystemWatcher.Linux.cs (1)
1086_eventQueue.Writer.Complete();