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)
248public override bool TryWrite(T item)
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
244public override bool TryWrite(T item)
181 references to TryWrite
aspire (23)
Diagnostics\FileLoggerProvider.cs (2)
166if (_channel.Writer.TryWrite(message)) 188_channel.Writer.TryWrite(message);
Interaction\ExtensionInteractionService.cs (21)
69var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(statusText.RemoveSpectreFormatting(), _cancellationToken)); 73result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken)); 80var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(statusText.RemoveSpectreFormatting(), _cancellationToken)); 84result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken)); 285var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayIncompatibleVersionErrorAsync(ex.RequiredCapability, appHostHostingSdkVersion, _cancellationToken)); 293var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayErrorAsync(errorMessage.RemoveSpectreFormatting(), _cancellationToken)); 300var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayMessageAsync(emoji.Name, message.RemoveSpectreFormatting(), _cancellationToken)); 307var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplaySuccessAsync(message.RemoveSpectreFormatting(), _cancellationToken)); 314var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplaySubtleMessageAsync(message.RemoveSpectreFormatting(), _cancellationToken)); 326var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayDashboardUrlsAsync(dashboardUrls, _cancellationToken)); 332var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayLinesAsync(lines.Select(line => new DisplayLineState(line.Stream.RemoveSpectreFormatting(), line.Line.RemoveSpectreFormatting())), _cancellationToken)); 339var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayCancellationMessageAsync(_cancellationToken)); 346var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayEmptyLineAsync(_cancellationToken)); 353var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.OpenEditorAsync(path, _cancellationToken)); 359var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayPlainTextAsync(text, _cancellationToken)); 372var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayPlainTextAsync(text, _cancellationToken)); 381var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.LogMessageAsync(LogLevel.Information, markdown, _cancellationToken)); 389var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.LogMessageAsync(LogLevel.Information, markup.RemoveSpectreFormatting(), _cancellationToken)); 411var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.LogMessageAsync(logLevel, message.RemoveSpectreFormatting(), _cancellationToken)); 427var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.NotifyAppHostStartupCompletedAsync(_cancellationToken)); 443var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.WriteDebugSessionMessageAsync(message.RemoveSpectreFormatting(), stdout, textStyle, _cancellationToken));
Aspire.Cli.Tests (2)
Commands\AgentMcpCommandTests.cs (2)
385notificationChannel.Writer.TryWrite(notification); 480notificationChannel.Writer.TryWrite(notification);
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 (9)
Components\Pages\ConsoleLogs.razor.cs (3)
777_logEntryChannel.Writer.TryWrite(new LogEntryToWrite(subscription.Resource.Name, LogEntry.CreatePause(GetResourceName(subscription.Resource), priorPause.Start, priorPause.End), LineNumber: null)); 797_logEntryChannel.Writer.TryWrite(new LogEntryToWrite(subscription.Resource.Name, logEntry, lineNumber)); 937_logEntryChannel.Writer.TryWrite(new LogEntryToWrite(subscription.Resource.Name, LogEntry.CreatePause(GetResourceName(subscription.Resource), timestamp), LineNumber: null));
Otlp\Storage\TelemetryRepository.Watchers.cs (2)
233if (!watcher.Channel.Writer.TryWrite(span)) 276if (!watcher.Channel.Writer.TryWrite(log))
ServiceClient\DashboardClient.cs (3)
441channel.Writer.TryWrite(changes); 514channel.Writer.TryWrite(response); 707channel.Writer.TryWrite(CreateLogLines(response.LogLines));
Telemetry\DashboardTelemetrySender.cs (1)
169_channel.Writer.TryWrite((context, requestFunc));
Aspire.Dashboard.Components.Tests (17)
Pages\ConsoleLogsTests.cs (14)
48subscribedResourceNamesChannel.Writer.TryWrite(name); 99subscribedResourceNamesChannel.Writer.TryWrite(name); 131consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Test content", IsErrorMessage: false)]); 369consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Hello world", IsErrorMessage: false)]); 510consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]); 526consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]); 570consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]); 582consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]); 638resourceChannel.Writer.TryWrite([ 705resourceCommandChannel.Writer.TryWrite(new ResourceCommandResponseViewModel 764consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, pauseContent, IsErrorMessage: false)]); 765consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, pauseContent, IsErrorMessage: false)]); 766consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(3, pauseContent, IsErrorMessage: false)]); 808consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(4, resumeContent, IsErrorMessage: false)]);
Pages\ResourcesTests.cs (2)
71channel.Writer.TryWrite([ 342channel.Writer.TryWrite(new[]
tests\Shared\TestDashboardTelemetrySender.cs (1)
23ContextChannel.Writer.TryWrite(context);
Aspire.Dashboard.Tests (13)
ChannelExtensionsTests.cs (8)
21channel.Writer.TryWrite(["a", "b", "c"]); 45channel.Writer.TryWrite(["a", "b", "c"]); 71channel.Writer.TryWrite(["a", "b", "c"]); 80resultChannel.Writer.TryWrite(batch); 94channel.Writer.TryWrite(["d", "e", "f"]); 115channel.Writer.TryWrite(["a", "b", "c"]); 124resultChannel.Writer.TryWrite(batch); 138channel.Writer.TryWrite(["d", "e", "f"]);
Integration\DashboardClientAuthTests.cs (1)
165testCalls.ResourceInformationCallsChannel.Writer.TryWrite(new ReceivedCallInfo<ApplicationInformationRequest>(request, context.RequestHeaders));
Model\AIAssistant\AIContextProviderTests.cs (1)
86changeChannel.Writer.TryWrite(provider.GetContext());
Model\AIAssistant\AssistantChatDataContextTests.cs (1)
113consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(i + 1, line, IsErrorMessage: false)]);
TelemetryRepositoryTests\LogTests.cs (1)
724resultChannel.Writer.TryWrite(callCount);
tests\Shared\TestDashboardTelemetrySender.cs (1)
23ContextChannel.Writer.TryWrite(context);
Aspire.Hosting (11)
ApplicationModel\ResourceLoggerService.cs (3)
237channel.Writer.TryWrite(new(name, hasSubscribers)); 319channel.Writer.TryWrite(logLines); 441void Log(LogEntry log) => channel.Writer.TryWrite(log);
ApplicationModel\ResourceNotificationService.cs (1)
561channel.Writer.TryWrite(resourceEvent);
Backchannel\BackchannelLoggerProvider.cs (1)
56subscriber.Writer.TryWrite(entry);
Dcp\DcpExecutor.cs (2)
389_logInformationChannel.Writer.TryWrite(new(subscribers.Name, LogsAvailable: null, subscribers.AnySubscribers)); 534_logInformationChannel.Writer.TryWrite(new(resource.Metadata.Name, LogsAvailable: true, HasSubscribers: null));
Dcp\ResourceLogSource.cs (1)
66var succeeded = channel.Writer.TryWrite((line, isError));
Devcontainers\DevcontainerSettingsWriter.cs (1)
51_portUpdates.Writer.TryWrite(new PortForwardEntry(url, port, protocol, label, openBrowser));
InteractionService.cs (1)
455channel.Writer.TryWrite(resourceEvent);
Pipelines\PipelineActivityReporter.cs (1)
189ActivityItemUpdated.Writer.TryWrite(state);
Aspire.Hosting.Azure.Tests (3)
tests\Shared\TestInteractionService.cs (3)
31Interactions.Writer.TryWrite(data); 39Interactions.Writer.TryWrite(data); 54Interactions.Writer.TryWrite(data);
Aspire.Hosting.Tests (15)
Cli\CliOrphanDetectorTests.cs (2)
125Assert.True(processRunningChannel.Writer.TryWrite(++processRunningCallCounter)); 196Assert.True(processRunningChannel.Writer.TryWrite(++processRunningCallCounter));
Dashboard\DashboardLifecycleHookTests.cs (1)
39testSink.MessageLogged += c => logChannel.Writer.TryWrite(c);
Dcp\DcpExecutorTests.cs (1)
612if (!logStreamPipesChannel.Writer.TryWrite((logStreamType, s)))
Dcp\TestKubernetesService.cs (3)
86c.Writer.TryWrite((WatchEventType.Added, res)); 99c.Writer.TryWrite((WatchEventType.Modified, resource)); 141chan.Writer.TryWrite((WatchEventType.Added, res));
Health\ResourceHealthCheckServiceTests.cs (1)
153channel.Writer.TryWrite(@event);
ResourceLoggerServiceTests.cs (2)
263consoleLogsChannel0.Writer.TryWrite([LogEntry.Create(timestamp: null, logMessage: "instance0!", isErrorMessage: false)]); 267consoleLogsChannel1.Writer.TryWrite([LogEntry.Create(timestamp: null, logMessage: "instance1!", isErrorMessage: false)]);
tests\Shared\TestInteractionService.cs (3)
31Interactions.Writer.TryWrite(data); 39Interactions.Writer.TryWrite(data); 54Interactions.Writer.TryWrite(data);
Utils\Grpc\TestAsyncStreamReader.cs (1)
24if (!_channel.Writer.TryWrite(message))
Utils\Grpc\TestServerStreamWriter.cs (1)
52if (!_channel.Writer.TryWrite(message))
GenerateDocumentationAndConfigFiles (2)
src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await 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( 424MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 449MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 468MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext);
TestTransport\InMemoryTransportFactory.cs (1)
21_acceptQueue.Writer.TryWrite(connection);
Metrics (2)
src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
Metrics.Legacy (2)
src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
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)
296var success = _http3TestBase._serverReceivedSettings.Writer.TryWrite( 424MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 449MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 468MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext);
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\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.AnalyzerUtilities (2)
src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.BannedApiAnalyzers (2)
src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.CodeStyle (2)
src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (2)
src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.PublicApiAnalyzers (2)
src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.ResxSourceGenerator (2)
src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.Threading.Package (2)
ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.Workspaces (2)
src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await 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\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await 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)
260channel.Writer.TryWrite($"Logged {logCount} messages.");
System.IO.FileSystem.Watcher (2)
System\IO\FileSystemWatcher.Linux.cs (2)
1218_eventQueue.Writer.TryWrite(ev); 1227_eventQueue.Writer.TryWrite(WatcherEvent.Error(exception));
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
1192if (!_writeChannel.Writer.TryWrite(writeEntry))
System.Net.Quic (4)
System\Net\Quic\QuicConnection.cs (1)
712if (!_acceptQueue.Writer.TryWrite(stream))
System\Net\Quic\QuicListener.cs (3)
248if (!_acceptQueue.Writer.TryWrite(connection)) 280if (!_acceptQueue.Writer.TryWrite(ex)) 315if (!_acceptQueue.Writer.TryWrite(
System.Threading.Channels (2)
System\Threading\Channels\ChannelWriter.cs (2)
45TryWrite(item) ? default : 58if (TryWrite(innerItem))
Test.Utilities (2)
src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
TestDiscoveryWorker (1)
Program.cs (1)
152if (!_channel.Writer.TryWrite(fullName))
Text.Analyzers (2)
src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);