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)
73 references to TryComplete
aspire (10)
Backchannel\AuxiliaryBackchannelMonitor.cs (2)
105connectionChanges.Writer.TryComplete(); 117connectionChanges.Writer.TryComplete();
Backchannel\ResourceSnapshotWatcher.cs (3)
136_updateSignal?.Writer.TryComplete(); 141_updateSignal?.Writer.TryComplete(); 146_updateSignal?.Writer.TryComplete(ex);
Commands\PsCommand.cs (1)
213updates.Writer.TryComplete();
Diagnostics\FileLoggerProvider.cs (1)
204_channel?.Writer.TryComplete();
Interaction\ExtensionInteractionService.cs (1)
617_extensionTaskChannel.Writer.TryComplete();
Projects\ProjectLocator.cs (2)
240candidateWriter.TryComplete(); 244candidateWriter.TryComplete(ex);
Aspire.Cli.Tests (1)
Backchannel\ResourceSnapshotWatcherTests.cs (1)
507source.Writer.TryComplete();
Aspire.Components.Common.TestUtilities (1)
ActivityNotifier.cs (1)
51_activityChannel.Writer.TryComplete();
Aspire.Dashboard (9)
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (4)
271channel.Writer.TryComplete(); 331channel.Writer.TryComplete(); 413watcher.Channel.Writer.TryComplete(); 417watcher.Channel.Writer.TryComplete();
ServiceClient\DashboardClient.cs (1)
968channel.Writer.TryComplete();
ServiceClient\SqliteResourceRepository.cs (2)
535channel.Writer.TryComplete(); 539channel.Writer.TryComplete();
Telemetry\DashboardTelemetrySender.cs (2)
106_channel.Writer.TryComplete(); 174_channel.Writer.TryComplete();
Aspire.Hosting (10)
ApplicationModel\ResourceLoggerService.cs (2)
462using var _ = _logStreamCts.Token.Register(() => channel.Writer.TryComplete()); 503channel.Writer.TryComplete();
ApplicationModel\ResourceNotificationService.cs (1)
814channel.Writer.TryComplete();
Backchannel\BackchannelLoggerProvider.cs (2)
41channel.Writer.TryComplete(); 77subscriber.Writer.TryComplete();
Dcp\ResourceLogSource.cs (3)
88channel.Writer.TryComplete(); 100channel.Writer.TryComplete(ex); 135channel.Writer.TryComplete();
Devcontainers\DevcontainerSettingsWriter.cs (1)
273_portUpdates.Writer.TryComplete();
InteractionService.cs (1)
681channel.Writer.TryComplete();
Aspire.Hosting.Foundry (1)
FoundryExtensions.cs (1)
412progressChannel.Writer.TryComplete();
Aspire.Hosting.Tests (2)
Dashboard\DashboardServiceTests.cs (1)
88getConsoleLogsChannel.Writer.TryComplete();
Dcp\TestKubernetesService.cs (1)
436_ = 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.DirectTls (3)
Connection\DirectTlsConnectionListener.cs (3)
159_readyConnections.Writer.TryComplete(error); 192_readyConnections.Writer.TryComplete(); 232_readyConnections.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)
2019invocationMessageChannel.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)
661_acceptQueue.Writer.TryComplete(exception); 672_acceptQueue.Writer.TryComplete(exception); 686_acceptQueue.Writer.TryComplete(exception); 863_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))