TryWrite

5 overrides of TryWrite

System.Threading.Channels (5)

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

363public override bool TryWrite(T item)

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

303public override bool TryWrite(T item)

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

279public override bool TryWrite(T item)

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

238public override bool TryWrite(T item)

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

244public override bool TryWrite(T item)

147 references to TryWrite

aspire (14)

Interaction\ExtensionInteractionService.cs (14)

Aspire.Cli.Tests (3)

Hosting\CliOrphanDetectorTests.cs (3)

40var lifetime = new HostLifetimeStub(() => stopSignalChannel.Writer.TryWrite(true)); 63var lifetime = new HostLifetimeStub(() => stopSignalChannel.Writer.TryWrite(true)); 68Assert.True(processRunningChannel.Writer.TryWrite(++processRunningCallCounter));

Aspire.Components.Common.TestUtilities (1)

ActivityNotifier.cs (1)

36_activityChannel.Writer.TryWrite(data);

Aspire.Confluent.Kafka (2)

AspireKafkaConsumerExtensions.cs (1)

233channel.Writer.TryWrite(json);

AspireKafkaProducerExtensions.cs (1)

233channel.Writer.TryWrite(json);

Aspire.Confluent.Kafka.Tests (2)

Aspire8MetricsTests.cs (2)

60writer.TryWrite(statistic); 175writer.TryWrite(statistic);

Aspire.Dashboard (4)

ServiceClient\DashboardClient.cs (3)

422channel.Writer.TryWrite(changes); 495channel.Writer.TryWrite(response); 666channel.Writer.TryWrite(CreateLogLines(response.LogLines));

Telemetry\DashboardTelemetrySender.cs (1)

169_channel.Writer.TryWrite((context, requestFunc));

Aspire.Dashboard.Components.Tests (17)

Pages\ConsoleLogsTests.cs (14)

Pages\ResourcesTests.cs (2)

69channel.Writer.TryWrite([ 340channel.Writer.TryWrite(new[]

tests\Shared\TestDashboardTelemetrySender.cs (1)

23ContextChannel.Writer.TryWrite(context);

Aspire.Dashboard.Tests (9)

ChannelExtensionsTests.cs (6)

21channel.Writer.TryWrite(["a", "b", "c"]); 45channel.Writer.TryWrite(["a", "b", "c"]); 71channel.Writer.TryWrite(["a", "b", "c"]); 94channel.Writer.TryWrite(["d", "e", "f"]); 115channel.Writer.TryWrite(["a", "b", "c"]); 138channel.Writer.TryWrite(["d", "e", "f"]);

Integration\DashboardClientAuthTests.cs (1)

165testCalls.ApplicationInformationCallsChannel.Writer.TryWrite(new ReceivedCallInfo<ApplicationInformationRequest>(request, context.RequestHeaders));

TelemetryRepositoryTests\LogTests.cs (1)

724resultChannel.Writer.TryWrite(callCount);

tests\Shared\TestDashboardTelemetrySender.cs (1)

23ContextChannel.Writer.TryWrite(context);

Aspire.Hosting (9)

ApplicationModel\InteractionService.cs (1)

223channel.Writer.TryWrite(resourceEvent);

ApplicationModel\ResourceLoggerService.cs (3)

231channel.Writer.TryWrite(new(name, hasSubscribers)); 302channel.Writer.TryWrite(logLines); 424void Log(LogEntry log) => channel.Writer.TryWrite(log);

ApplicationModel\ResourceNotificationService.cs (1)

463channel.Writer.TryWrite(resourceEvent);

Backchannel\BackchannelLoggerProvider.cs (1)

87channel.Writer.TryWrite(entry);

Dcp\DcpExecutor.cs (2)

241_logInformationChannel.Writer.TryWrite(new(subscribers.Name, LogsAvailable: null, subscribers.AnySubscribers)); 381_logInformationChannel.Writer.TryWrite(new(resource.Metadata.Name, LogsAvailable: true, HasSubscribers: null));

Dcp\ResourceLogSource.cs (1)

82var succeeded = channel.Writer.TryWrite((line, isError));

Aspire.Hosting.Tests (6)

Dashboard\DashboardLifecycleHookTests.cs (1)

40testSink.MessageLogged += c => logChannel.Writer.TryWrite(c);

Dcp\DcpExecutorTests.cs (1)

572if (!logStreamPipesChannel.Writer.TryWrite((logStreamType, s)))

Dcp\TestKubernetesService.cs (1)

99c.Writer.TryWrite((WatchEventType.Modified, resource));

Health\ResourceHealthCheckServiceTests.cs (1)

154channel.Writer.TryWrite(@event);

Utils\Grpc\TestAsyncStreamReader.cs (1)

24if (!_channel.Writer.TryWrite(message))

Utils\Grpc\TestServerStreamWriter.cs (1)

52if (!_channel.Writer.TryWrite(message))

GenerateDocumentationAndConfigFiles (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

InMemory.FunctionalTests (5)

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

296var success = _http3TestBase._serverReceivedSettings.Writer.TryWrite( 410MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 435MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 454MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext);

TestTransport\InMemoryTransportFactory.cs (1)

21_acceptQueue.Writer.TryWrite(connection);

Metrics (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

Metrics.Legacy (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

Microsoft.AspNetCore.ConcurrencyLimiter.Tests (1)

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

63writer.TryWrite(value);

Microsoft.AspNetCore.Hosting.Tests (1)

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

63writer.TryWrite(value);

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

TestWebSocketConnectionFeature.cs (1)

257if (_output.TryWrite(webSocketMessage))

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

Internal\Http2\Http2FrameWriter.cs (1)

166if (!_channel.Writer.TryWrite(producer))

Internal\WebTransport\WebTransportSession.cs (1)

155if (!addedToOpenStreams || !_pendingStreams.Writer.TryWrite(stream))

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

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

Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)

Internal\NamedPipeConnectionListener.cs (1)

119while (!_acceptedQueue.Writer.TryWrite(connection))

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

HubConnectionExtensions.StreamAsChannelAsync.cs (1)

295while (!outputChannel.Writer.TryWrite((TResult)item!))

Internal\InvocationRequest.cs (1)

139while (!_channel.Writer.TryWrite(item))

src\SignalR\common\Shared\MessageBuffer.cs (1)

207_waitForAck.Writer.TryWrite(newCount);

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

HubConnectionTests.cs (1)

2945_taskQueue.Writer.TryWrite((d, state));

HubConnectionTests.Tracing.cs (7)

48clientChannel.Writer.TryWrite(activity); 52serverChannel.Writer.TryWrite(activity); 247serverChannel.Writer.TryWrite(activity); 391serverChannel.Writer.TryWrite(activity); 494serverChannel.Writer.TryWrite(activity); 590serverChannel.Writer.TryWrite(activity); 680serverChannel.Writer.TryWrite(activity);

Microsoft.AspNetCore.SignalR.Core (3)

Internal\ChannelBasedSemaphore.cs (2)

20_channel.Writer.TryWrite(1); 37if (!_channel.Writer.TryWrite(1))

src\SignalR\common\Shared\MessageBuffer.cs (1)

207_waitForAck.Writer.TryWrite(newCount);

Microsoft.AspNetCore.SignalR.Tests (8)

HubConnectionHandlerTests.Activity.cs (8)

40ActivityStarted = a => serverChannel.Writer.TryWrite(a) 115ActivityStarted = a => serverChannel.Writer.TryWrite(a) 184ActivityStarted = a => serverChannel.Writer.TryWrite(a) 243ActivityStarted = a => serverChannel.Writer.TryWrite(a) 316ActivityStarted = a => serverChannel.Writer.TryWrite(a) 363ActivityStarted = a => serverChannel.Writer.TryWrite(a) 415ActivityStarted = a => serverChannel.Writer.TryWrite(a) 466ActivityStarted = a => serverChannel.Writer.TryWrite(a)

Microsoft.CodeAnalysis.Analyzers (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.AnalyzerUtilities (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.BannedApiAnalyzers (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.CodeStyle (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.PublicApiAnalyzers (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.ResxSourceGenerator (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.Workspaces (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

Microsoft.ML.Data (1)

Transforms\RowShufflingTransformer.cs (1)

557bool retval = target.Writer.TryWrite(item);

Microsoft.ML.Sweeper (1)

AsyncSweeper.cs (1)

229_paramChannel.Writer.TryWrite(new ParameterSetWithId(_numGenerated++, paramSet));

Roslyn.Diagnostics.Analyzers (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

SignalR.Client.FunctionalTestApp (3)

TestHub.cs (3)

63channel.Writer.TryWrite("a"); 64channel.Writer.TryWrite("b"); 65channel.Writer.TryWrite("c");

SignalRSamples (1)

ObservableExtensions.cs (1)

29value => channel.Writer.TryWrite(value),

Stress.ApiService (1)

Program.cs (1)

189channel.Writer.TryWrite($"Logged {logCount} messages.");

System.Net.Http (1)

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

1189if (!_writeChannel.Writer.TryWrite(writeEntry))

System.Net.Quic (4)

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

711if (!_acceptQueue.Writer.TryWrite(stream))

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

246if (!_acceptQueue.Writer.TryWrite(connection)) 278if (!_acceptQueue.Writer.TryWrite(ex)) 313if (!_acceptQueue.Writer.TryWrite(

System.Threading.Channels (2)

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

45TryWrite(item) ? default : 58if (TryWrite(innerItem))

Test.Utilities (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);

TestDiscoveryWorker (1)

Program.cs (1)

151if (!_channel.Writer.TryWrite(fullName))

Text.Analyzers (2)

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

286args.channel.Writer.TryWrite(item); 384await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);