TryComplete

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)

96 references to TryComplete

Aspire.Components.Common.TestUtilities (1)

ActivityNotifier.cs (1)

51_activityChannel.Writer.TryComplete();

Aspire.Dashboard (3)

ServiceClient\DashboardClient.cs (1)

671channel.Writer.TryComplete();

Telemetry\DashboardTelemetrySender.cs (2)

106_channel.Writer.TryComplete(); 174_channel.Writer.TryComplete();

Aspire.Hosting (7)

ApplicationModel\InteractionService.cs (1)

253channel.Writer.TryComplete();

ApplicationModel\ResourceLoggerService.cs (2)

421using var _ = _logStreamCts.Token.Register(() => channel.Writer.TryComplete()); 462channel.Writer.TryComplete();

ApplicationModel\ResourceNotificationService.cs (1)

511channel.Writer.TryComplete();

Dcp\ResourceLogSource.cs (3)

59channel.Writer.TryComplete(); 86channel.Writer.TryComplete(); 98channel.Writer.TryComplete(ex);

Aspire.Hosting.Tests (2)

Dashboard\DashboardServiceTests.cs (1)

83getConsoleLogsChannel.Writer.TryComplete();

Dcp\TestKubernetesService.cs (1)

241_ = c.Writer.TryComplete();

ClientSample (2)

UploadSample.cs (2)

52channel.Writer.TryComplete(); 79source.TryComplete();

GenerateDocumentationAndConfigFiles (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

353static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)), 411writer.TryComplete(exception);

InMemory.FunctionalTests (3)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

1049ToServerAcceptQueue.Writer.TryComplete(); 1050ToClientAcceptQueue.Writer.TryComplete();

TestTransport\InMemoryTransportFactory.cs (1)

52_acceptQueue.Writer.TryComplete();

Metrics (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

356() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 411writer.TryComplete(exception);

Metrics.Legacy (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

356() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 411writer.TryComplete(exception);

Microsoft.AspNetCore.ConcurrencyLimiter.Tests (1)

src\Shared\EventSource.Testing\TestCounterListener.cs (1)

72item.Value.Writer.TryComplete();

Microsoft.AspNetCore.Hosting.Tests (1)

src\Shared\EventSource.Testing\TestCounterListener.cs (1)

72item.Value.Writer.TryComplete();

Microsoft.AspNetCore.Http.Connections.Tests (6)

TestWebSocketConnectionFeature.cs (6)

85_output.TryComplete(new OperationCanceledException()); 91_output.TryComplete(new WebSocketException(WebSocketError.ConnectionClosedPrematurely)); 106_output.TryComplete(); 121_output.TryComplete(); 127_output.TryComplete(); 183_output.TryComplete();

Microsoft.AspNetCore.Server.Kestrel.Core (1)

Internal\Http2\Http2FrameWriter.cs (1)

453_channel.Writer.TryComplete();

Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (2)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

1049ToServerAcceptQueue.Writer.TryComplete(); 1050ToClientAcceptQueue.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)

1711invocationMessageChannel.Writer.TryComplete();

HubConnectionExtensions.StreamAsChannelAsync.cs (2)

308outputChannel.Writer.TryComplete(ex); 313outputChannel.Writer.TryComplete();

Internal\InvocationRequest.cs (4)

103_channel.Writer.TryComplete(new InvalidOperationException("Server provided a result in a completion response to a streamed invocation.")); 118_channel.Writer.TryComplete(); 132_channel.Writer.TryComplete(exception); 163_channel.Writer.TryComplete(new OperationCanceledException());

Microsoft.AspNetCore.SignalR.Client.FunctionalTests (3)

Hubs.cs (3)

237channel.Writer.TryComplete(); 267output.Writer.TryComplete(); 291output.Writer.TryComplete();

Microsoft.AspNetCore.SignalR.Client.Tests (2)

HubConnectionTests.cs (2)

456channel.Writer.TryComplete(); 528channel.Writer.TryComplete();

Microsoft.AspNetCore.SignalR.Core (1)

StreamTracker.cs (1)

139_channel.Writer.TryComplete(ex);

Microsoft.AspNetCore.SignalR.Tests (12)

HubConnectionHandlerTestUtils\Hubs.cs (10)

NativeAotTests.cs (2)

258output.Writer.TryComplete(); 292output.Writer.TryComplete();

Microsoft.CodeAnalysis.Analyzers (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

356() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 411writer.TryComplete(exception);

Microsoft.CodeAnalysis.AnalyzerUtilities (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

356() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 411writer.TryComplete(exception);

Microsoft.CodeAnalysis.BannedApiAnalyzers (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

356() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 411writer.TryComplete(exception);

Microsoft.CodeAnalysis.CodeStyle (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

356() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 411writer.TryComplete(exception);

Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

356() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 411writer.TryComplete(exception);

Microsoft.CodeAnalysis.PublicApiAnalyzers (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

356() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 411writer.TryComplete(exception);

Microsoft.CodeAnalysis.ResxSourceGenerator (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

356() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 411writer.TryComplete(exception);

Microsoft.CodeAnalysis.Workspaces (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

353static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)), 411writer.TryComplete(exception);

Microsoft.Extensions.AI (1)

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

159_ = updates.Writer.TryComplete(error);

Roslyn.Diagnostics.Analyzers (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

356() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 411writer.TryComplete(exception);

SignalRSamples (4)

Hubs\Streaming.cs (1)

42channel.Writer.TryComplete();

ObservableExtensions.cs (3)

30error => channel.Writer.TryComplete(error), 31() => channel.Writer.TryComplete()); 32var abortRegistration = connectionAborted.Register(() => channel.Writer.TryComplete());

System.Net.Http (1)

System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)

1861bool completed = _writeChannel.Writer.TryComplete();

System.Net.Quic (5)

System\Net\Quic\QuicConnection.cs (4)

660_acceptQueue.Writer.TryComplete(exception); 671_acceptQueue.Writer.TryComplete(exception); 685_acceptQueue.Writer.TryComplete(exception); 862_acceptQueue.Writer.TryComplete(ExceptionDispatchInfo.SetCurrentStackTrace(new ObjectDisposedException(GetType().FullName)));

System\Net\Quic\QuicListener.cs (1)

430_acceptQueue.Writer.TryComplete(ExceptionDispatchInfo.SetCurrentStackTrace(new ObjectDisposedException(GetType().FullName)));

System.Threading.Channels (1)

System\Threading\Channels\ChannelWriter.cs (1)

72if (!TryComplete(error))

Test.Utilities (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

353static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)), 411writer.TryComplete(exception);

Text.Analyzers (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (2)

356() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 411writer.TryComplete(exception);