49 references to Complete
Aspire.Cli.Tests (1)
Commands\LogsCommandTests.cs (1)
1481logLines.Writer.Complete();
Aspire.Dashboard.Components.Tests (4)
Pages\ConsoleLogsTests.cs (4)
133consoleLogsChannel.Writer.Complete(); 168subscribedResourceNamesChannel.Writer.Complete(); 536consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!")); 587consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!"));
Aspire.Dashboard.Tests (13)
ChannelExtensionsTests.cs (3)
124resultChannel.Writer.Complete(); 141channel.Writer.Complete(); 168resultChannel.Writer.Complete();
Model\DashboardClientTests.cs (6)
568firstInteractions.Writer.Complete(new RpcException(new Status(StatusCode.Unavailable, "Interaction stream disconnected"))); 634first.Writer.Complete(failStream ? new RpcException(new Status(StatusCode.Unavailable, "Resource stream disconnected")) : null); 643second.Writer.Complete(failStream ? new RpcException(new Status(StatusCode.Unavailable, "Resource stream disconnected again")) : null); 1134first.Writer.Complete(failStream ? new RpcException(new Status(StatusCode.Unavailable, "Disconnected")) : null); 1177channel.Writer.Complete(); 1211channel.Writer.Complete(new RpcException(new Status(StatusCode.Unimplemented, "Older AppHost")));
ResourceOutgoingPeerResolverTests.cs (4)
333resultChannel.Writer.Complete(); 365sourceChannel.Writer.Complete(); 391sourceChannel.Writer.Complete(); 417sourceChannel.Writer.Complete();
Aspire.Hosting (3)
ApplicationModel\ResourceLoggerService.cs (2)
266channel.Writer.Complete(); 334channel.Writer.Complete();
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
1707completeWriterTask = Task.WhenAll(tasks).ContinueWith(_ => channel.Writer.Complete(), CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
Aspire.Hosting.Tests (11)
Dcp\DcpExecutorTests.cs (1)
3915logStreamPipesChannel.Writer.Complete();
ResourceCommandServiceTests.cs (2)
156commandResourcesChannel.Writer.Complete(); 194commandResourcesChannel.Writer.Complete();
ResourceLoggerServiceTests.cs (3)
265consoleLogsChannel0.Writer.Complete(); 269consoleLogsChannel1.Writer.Complete(); 484consoleLogsChannel.Writer.Complete();
VersionChecking\VersionCheckServiceTests.cs (5)
97interactionService.Interactions.Writer.Complete(); 181interactionService.Interactions.Writer.Complete(); 212interactionService.Interactions.Writer.Complete(); 241interactionService.Interactions.Writer.Complete(); 282interactionService.Interactions.Writer.Complete();
Aspire.Hosting.TestUtilities (2)
Utils\Grpc\TestAsyncStreamReader.cs (1)
32_channel.Writer.Complete(ex);
Utils\Grpc\TestServerStreamWriter.cs (1)
27_channel.Writer.Complete(ex);
dotnet-aot (1)
parent\dotnet\Commands\Test\MTP\TestApplicationActionQueue.cs (1)
95_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)
366channel.Writer.Complete();
System.IO.FileSystem.Watcher (1)
System\IO\FileSystemWatcher.Linux.cs (1)
1095_eventQueue.Writer.Complete();