5 overrides of TryComplete
System.Threading.Channels (5)
System\Threading\Channels\BoundedChannel.cs (1)
305public override bool TryComplete(Exception? error)
System\Threading\Channels\RendezvousChannel.cs (1)
252public override bool TryComplete(Exception? error)
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
209public override bool TryComplete(Exception? error)
System\Threading\Channels\UnboundedChannel.cs (1)
188public override bool TryComplete(Exception? error)
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
194public override bool TryComplete(Exception? error)
83 references to TryComplete
aspire (11)
Backchannel\AuxiliaryBackchannelMonitor.cs (2)
117connectionChanges.Writer.TryComplete(); 138connectionChanges.Writer.TryComplete();
Backchannel\ResourceSnapshotWatcher.cs (3)
74_updateSignal?.Writer.TryComplete(); 92_updateSignal?.Writer.TryComplete(); 97_updateSignal?.Writer.TryComplete(ex);
Backchannel\TrayWatchStream.cs (1)
177updates.Writer.TryComplete();
Commands\PsCommand.cs (1)
260updates.Writer.TryComplete();
Diagnostics\FileLoggerProvider.cs (1)
212_channel?.Writer.TryComplete();
Interaction\ExtensionInteractionService.cs (1)
727_extensionTaskChannel.Writer.TryComplete();
Projects\ProjectLocator.cs (2)
240candidateWriter.TryComplete(); 244candidateWriter.TryComplete(ex);
Aspire.Cli.Tests (3)
Backchannel\ResourceSnapshotWatcherTests.cs (1)
596source.Writer.TryComplete();
Backchannel\TrayWatchStreamTests.cs (2)
719resourceUpdates.Writer.TryComplete(); 781resourceUpdates.Writer.TryComplete(fails ? new IOException("Resource stream failed.") : null);
Aspire.Components.Common.TestUtilities (1)
ActivityNotifier.cs (1)
51_activityChannel.Writer.TryComplete();
Aspire.Dashboard (7)
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (4)
270channel.Writer.TryComplete(); 330channel.Writer.TryComplete(); 412watcher.Channel.Writer.TryComplete(); 416watcher.Channel.Writer.TryComplete();
ServiceClient\DashboardClient.cs (1)
1029channel.Writer.TryComplete();
ServiceClient\SqliteResourceRepository.cs (2)
542channel.Writer.TryComplete(); 546channel.Writer.TryComplete();
Aspire.Dashboard.Components.Tests (2)
tests\Shared\DashboardTelemetryFixture.cs (2)
84ActivityChannel.Writer.TryComplete(); 85LogChannel.Writer.TryComplete();
Aspire.Dashboard.Tests (4)
Model\DashboardClientTests.cs (2)
147channel.Writer.TryComplete(error); 171channel.Writer.TryComplete(new RpcException(new Status(statusCode, "Terminal is unavailable.")));
tests\Shared\DashboardTelemetryFixture.cs (2)
84ActivityChannel.Writer.TryComplete(); 85LogChannel.Writer.TryComplete();
Aspire.Hosting (13)
ApplicationModel\ResourceLoggerService.cs (2)
462using var _ = _logStreamCts.Token.Register(() => channel.Writer.TryComplete()); 503channel.Writer.TryComplete();
ApplicationModel\ResourceNotificationService.cs (1)
851channel.Writer.TryComplete();
ApplicationModel\TerminalService.cs (3)
318channel.Writer.TryComplete(); 374channel.Writer.TryComplete(); 501channel.Writer.TryComplete();
Backchannel\BackchannelLoggerProvider.cs (2)
41channel.Writer.TryComplete(); 77subscriber.Writer.TryComplete();
Dcp\ResourceLogSource.cs (3)
95channel.Writer.TryComplete(); 107channel.Writer.TryComplete(ex); 148channel.Writer.TryComplete();
Devcontainers\DevcontainerSettingsWriter.cs (1)
273_portUpdates.Writer.TryComplete();
InteractionService.cs (1)
724channel.Writer.TryComplete();
Aspire.Hosting.DevTunnels (1)
DevTunnelMonitor.cs (1)
763_operations.Writer.TryComplete();
Aspire.Hosting.Foundry (1)
FoundryExtensions.cs (1)
495progressChannel.Writer.TryComplete();
Aspire.Hosting.RemoteHost (2)
src\Shared\ChildProcess.cs (2)
721lines.Writer.TryComplete(); 727lines.Writer.TryComplete(ex);
Aspire.Hosting.Tests (2)
Dashboard\DashboardServiceTests.cs (1)
93getConsoleLogsChannel.Writer.TryComplete();
Dcp\TestKubernetesService.cs (1)
485_ = c.Writer.TryComplete();
Aspire.TerminalHost (1)
DcpUpstreamAdapter.cs (1)
462_outputChannel.Writer.TryComplete(error);
GenerateDocumentationAndConfigFiles (2)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
336static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)), 394writer.TryComplete(exception);
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http2\Http2FrameWriter.cs (1)
453_channel.Writer.TryComplete();
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (2)
Internal\NamedPipeConnectionListener.cs (2)
89_acceptedQueue.Writer.TryComplete(); 93_acceptedQueue.Writer.TryComplete(ex);
Microsoft.AspNetCore.SignalR.Client.Core (7)
HubConnection.cs (1)
2026invocationMessageChannel.Writer.TryComplete();
HubConnectionExtensions.StreamAsChannelAsync.cs (2)
308outputChannel.Writer.TryComplete(ex); 313outputChannel.Writer.TryComplete();
Internal\InvocationRequest.cs (4)
110_channel.Writer.TryComplete(new InvalidOperationException("Server provided a result in a completion response to a streamed invocation.")); 125_channel.Writer.TryComplete(); 139_channel.Writer.TryComplete(exception); 170_channel.Writer.TryComplete(new OperationCanceledException());
Microsoft.AspNetCore.SignalR.Core (1)
StreamTracker.cs (1)
164_channel.Writer.TryComplete(ex);
Microsoft.CodeAnalysis.Analyzers (2)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 394writer.TryComplete(exception);
Microsoft.CodeAnalysis.AnalyzerUtilities (2)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 394writer.TryComplete(exception);
Microsoft.CodeAnalysis.CodeStyle (2)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 394writer.TryComplete(exception);
Microsoft.CodeAnalysis.ResxSourceGenerator (2)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 394writer.TryComplete(exception);
Microsoft.CodeAnalysis.Workspaces (2)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
336static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)), 394writer.TryComplete(exception);
Microsoft.Extensions.AI (1)
ChatCompletion\AnonymousDelegatingChatClient.cs (1)
157_ = updates.Writer.TryComplete(error);
Roslyn.Diagnostics.Analyzers (2)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 394writer.TryComplete(exception);
System.Diagnostics.Process (2)
System\Diagnostics\Process.Multiplexing.cs (2)
582channel.Writer.TryComplete(ex); 588channel.Writer.TryComplete();
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
1941bool completed = _writeChannel.Writer.TryComplete();
System.Net.Quic (5)
System\Net\Quic\QuicConnection.cs (4)
664_acceptQueue.Writer.TryComplete(exception); 675_acceptQueue.Writer.TryComplete(exception); 689_acceptQueue.Writer.TryComplete(exception); 866_acceptQueue.Writer.TryComplete(ExceptionDispatchInfo.SetCurrentStackTrace(new ObjectDisposedException(GetType().FullName)));
System\Net\Quic\QuicListener.cs (1)
432_acceptQueue.Writer.TryComplete(ExceptionDispatchInfo.SetCurrentStackTrace(new ObjectDisposedException(GetType().FullName)));
System.Threading.Channels (1)
System\Threading\Channels\ChannelWriter.cs (1)
72if (!TryComplete(error))