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)
47 references to TryComplete
aspire (1)
Diagnostics\FileLoggerProvider.cs (1)
214_channel?.Writer.TryComplete();
Aspire.Components.Common.TestUtilities (1)
ActivityNotifier.cs (1)
51_activityChannel.Writer.TryComplete();
Aspire.Dashboard (7)
Otlp\Storage\TelemetryRepository.Watchers.cs (4)
114channel.Writer.TryComplete(); 205channel.Writer.TryComplete(); 309watcher.Channel.Writer.TryComplete(); 318watcher.Channel.Writer.TryComplete();
ServiceClient\DashboardClient.cs (1)
713channel.Writer.TryComplete();
Telemetry\DashboardTelemetrySender.cs (2)
106_channel.Writer.TryComplete(); 174_channel.Writer.TryComplete();
Aspire.Hosting (10)
ApplicationModel\ResourceLoggerService.cs (2)
438using var _ = _logStreamCts.Token.Register(() => channel.Writer.TryComplete()); 479channel.Writer.TryComplete();
ApplicationModel\ResourceNotificationService.cs (1)
628channel.Writer.TryComplete();
Backchannel\BackchannelLoggerProvider.cs (2)
39channel.Writer.TryComplete(); 72subscriber.Writer.TryComplete();
Dcp\ResourceLogSource.cs (3)
70channel.Writer.TryComplete(); 82channel.Writer.TryComplete(ex); 117channel.Writer.TryComplete();
Devcontainers\DevcontainerSettingsWriter.cs (1)
273_portUpdates.Writer.TryComplete();
InteractionService.cs (1)
485channel.Writer.TryComplete();
Aspire.Hosting.Tests (2)
Dashboard\DashboardServiceTests.cs (1)
84getConsoleLogsChannel.Writer.TryComplete();
Dcp\TestKubernetesService.cs (1)
241_ = c.Writer.TryComplete();
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.SignalR.Core (1)
StreamTracker.cs (1)
139_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)
1864bool 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))