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)
278public 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)
239 references to TryWrite
aspire (34)
Backchannel\AuxiliaryBackchannelMonitor.cs (1)
89void QueueConnectionChange() => connectionChanges.Writer.TryWrite(true);
Backchannel\ResourceSnapshotWatcher.cs (1)
223_updateSignal?.Writer.TryWrite(true);
Backchannel\TrayWatchStream.cs (2)
163updates.Writer.TryWrite(update); 240connection, host, () => healthChanges.Writer.TryWrite(true), logger, token));
Diagnostics\FileLoggerProvider.cs (2)
152if (_channel.Writer.TryWrite(message)) 174_channel.Writer.TryWrite(message);
Interaction\ExtensionInteractionService.cs (28)
89var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(StringUtils.RemoveMarkup(statusText), _cancellationToken)); 99result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken)); 106var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(StringUtils.RemoveMarkup(initialStatusText), _cancellationToken)); 115var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(StringUtils.RemoveMarkup(statusText), _cancellationToken)); 123result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken)); 130var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(StringUtils.RemoveMarkup(statusText), _cancellationToken)); 140result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken)); 387var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayIncompatibleVersionErrorAsync(ex.RequiredCapability, appHostHostingSdkVersion, _cancellationToken)); 400var result = _extensionTaskChannel.Writer.TryWrite(async () => 411var result = _extensionTaskChannel.Writer.TryWrite(async () => 421var result = _extensionTaskChannel.Writer.TryWrite(async () => 432var result = _extensionTaskChannel.Writer.TryWrite(async () => 442var result = _extensionTaskChannel.Writer.TryWrite(() => 526var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplaySuccessAsync(StringUtils.RemoveMarkup(message), _cancellationToken)); 533var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplaySubtleMessageAsync(StringUtils.RemoveMarkup(message), _cancellationToken)); 545var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayDashboardUrlsAsync(dashboardUrls, _cancellationToken)); 554var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayLinesAsync(materialized.Select(line => new DisplayLineState( 569var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayCancellationMessageAsync(_cancellationToken)); 576var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayEmptyLineAsync(_cancellationToken)); 583var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.OpenEditorAsync(path, _cancellationToken)); 589var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayPlainTextAsync(text, _cancellationToken)); 606var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayPlainTextAsync(text, _cancellationToken)); 615var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.LogMessageAsync(LogLevel.Information, markdown, _cancellationToken)); 623var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.LogMessageAsync(LogLevel.Information, StringUtils.RemoveMarkup(markup), _cancellationToken)); 645var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.LogMessageAsync(logLevel, StringUtils.RemoveMarkup(message), _cancellationToken)); 661var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.NotifyAppHostStartupCompletedAsync(_cancellationToken)); 677var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.WriteDebugSessionMessageAsync(StringUtils.RemoveMarkup(message), stdout, textStyle, _cancellationToken)); 683var result = _extensionTaskChannel.Writer.TryWrite(async () => await Backchannel.WriteAppHostLogEntryAsync(entry, _cancellationToken).ConfigureAwait(false));
aspire-tray (1)
NativeSmokeHarness.cs (1)
550=> Require(_snapshots.Writer.TryWrite(snapshot), "The smoke snapshot channel is closed.");
Aspire.Cli.Tests (31)
Backchannel\TrayWatchStreamTests.cs (27)
116snapshots.Writer.TryWrite([second, first]); 126snapshots.Writer.TryWrite([second]); 130snapshots.Writer.TryWrite([]); 399messages.Writer.TryWrite(Deserialize(json)); 521batches.Writer.TryWrite(count); 581snapshots.Writer.TryWrite(hung); 584messages.Writer.TryWrite(Deserialize(json)); 609snapshots.Writer.TryWrite(saturateSlots ? [newcomer] : [hung[0], healthy, newcomer]); 685snapshots.Writer.TryWrite([connection]); 690messages.Writer.TryWrite(Deserialize(json)); 700resourceUpdates.Writer.TryWrite(new() { Name = "api", State = "Running", HealthStatus = "Healthy", Version = 2 }); 703resourceUpdates.Writer.TryWrite(new() { Name = "cache", State = "Running", HealthStatus = "Degraded", Version = 2 }); 706resourceUpdates.Writer.TryWrite(new() { Name = "cache", State = "Running", HealthStatus = "Unhealthy", Version = 3 }); 709resourceUpdates.Writer.TryWrite(new() { Name = "cache", State = "Running", HealthStatus = "Healthy", Version = 4 }); 712resourceUpdates.Writer.TryWrite(new() { Name = "api", State = "Running", HealthStatus = "Unhealthy", Version = 1 }); 713resourceUpdates.Writer.TryWrite(new() { Name = "cache", State = "FailedToStart", Version = 5 }); 716resourceUpdates.Writer.TryWrite(new() { Name = "cache", State = "FailedToStart", IsHidden = true, Version = 6 }); 774messages.Writer.TryWrite(Deserialize(json)); 813snapshots.Writer.TryWrite([initial]); 817messages.Writer.TryWrite(Deserialize(json)); 827snapshots.Writer.TryWrite([]); 832snapshots.Writer.TryWrite([replacement]); 886snapshots.Writer.TryWrite([initial]); 893messages.Writer.TryWrite(Deserialize(json)); 902snapshots.Writer.TryWrite([]); 905snapshots.Writer.TryWrite([replacement]); 912snapshots.Writer.TryWrite([replacement]);
Commands\AgentMcpCommandTests.cs (2)
359notificationChannel.Writer.TryWrite(notification); 446notificationChannel.Writer.TryWrite(notification);
Commands\LogsCommandTests.cs (1)
1440logLines.Writer.TryWrite(line);
TestServices\TestAuxiliaryBackchannelMonitor.cs (1)
68_connectionChanges.Writer.TryWrite(true);
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 (12)
Api\TelemetryApiService.cs (1)
531signal.Writer.TryWrite(true);
Components\Pages\ConsoleLogs.razor.cs (3)
832_logEntryChannel.Writer.TryWrite(new LogEntryToWrite(subscription.Resource.Name, LogEntry.CreatePause(GetResourceName(subscription.Resource), priorPause.Start, priorPause.End), LineNumber: null)); 852_logEntryChannel.Writer.TryWrite(new LogEntryToWrite(subscription.Resource.Name, logEntry, lineNumber)); 1005_logEntryChannel.Writer.TryWrite(new LogEntryToWrite(subscription.Resource.Name, LogEntry.CreatePause(GetResourceName(subscription.Resource), timestamp), LineNumber: null));
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (2)
365watcher.Channel.Writer.TryWrite(span); 400watcher.Channel.Writer.TryWrite(log);
ServiceClient\DashboardClient.cs (3)
732channel.Writer.TryWrite(changes); 809channel.Writer.TryWrite(response); 1024channel.Writer.TryWrite(CreateLogLines(response.LogLines));
ServiceClient\SqliteResourceRepository.cs (2)
390channel.Writer.TryWrite(viewModelLines); 512channel.Writer.TryWrite(changes);
Telemetry\DashboardTelemetrySender.cs (1)
170_channel.Writer.TryWrite((context, requestFunc));
Aspire.Dashboard.Components.Tests (26)
Controls\TerminalWindowButtonTests.cs (2)
230.Add(p => p.OnWindowsAdopted, keys => { checkedKeys.Writer.TryWrite(keys); })); 321.Add(p => p.OnWindowTrackingFailed, keys => { failedKeys.Writer.TryWrite(keys); }));
Interactions\InteractionsProviderTests.Terminal.cs (2)
34shown.Writer.TryWrite((content, parameters)); 93shown.Writer.TryWrite((content, parameters));
Layout\TerminalDockInitializationTests.cs (1)
30OnTerminalUpdateProcessed = update => processed.Writer.TryWrite(update)
Layout\TerminalDockWindowTrackingTests.cs (1)
187started.Writer.TryWrite(true);
Pages\ConsoleLogsTests.cs (17)
49subscribedResourceNamesChannel.Writer.TryWrite(name); 100subscribedResourceNamesChannel.Writer.TryWrite(name); 132consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Test content", IsErrorMessage: false)]); 359consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Hello world", IsErrorMessage: false)]); 399liveConsoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Live log", IsErrorMessage: false)]); 446consoleLogsChannel.Writer.TryWrite([ 629consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]); 654consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]); 735consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]); 747consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]); 774consoleLogsChannel.Writer.TryWrite([ 838resourceChannel.Writer.TryWrite([ 950resourceCommandChannel.Writer.TryWrite(new ResourceCommandResponseViewModel 1021consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, pauseContent, IsErrorMessage: false)]); 1022consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, pauseContent, IsErrorMessage: false)]); 1023consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(3, pauseContent, IsErrorMessage: false)]); 1069consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(4, resumeContent, IsErrorMessage: false)]);
Pages\ResourcesTests.cs (2)
242channel.Writer.TryWrite([ 782channel.Writer.TryWrite(new[]
tests\Shared\TestDashboardTelemetrySender.cs (1)
23ContextChannel.Writer.TryWrite(context);
Aspire.Dashboard.Tests (15)
ChannelExtensionsTests.cs (8)
60channel.Writer.TryWrite(["a", "b", "c"]); 84channel.Writer.TryWrite(["a", "b", "c"]); 110channel.Writer.TryWrite(["a", "b", "c"]); 119resultChannel.Writer.TryWrite(batch); 133channel.Writer.TryWrite(["d", "e", "f"]); 154channel.Writer.TryWrite(["a", "b", "c"]); 163resultChannel.Writer.TryWrite(batch); 177channel.Writer.TryWrite(["d", "e", "f"]);
Integration\DashboardClientAuthTests.cs (1)
180testCalls.ResourceInformationCallsChannel.Writer.TryWrite(new ReceivedCallInfo<ApplicationInformationRequest>(request, context.RequestHeaders));
Model\DashboardClientTests.cs (4)
44channel.Writer.TryWrite(new TerminalServerFrame { Ended = true }); 124channel.Writer.TryWrite(new TerminalServerFrame { Ended = true }); 618subscriptionsStarted.Writer.TryWrite(attempt); 1110OnTerminalWatchDisposed = () => disposed.Writer.TryWrite(true)
TelemetryRepositoryTests\LogTests.cs (1)
978resultChannel.Writer.TryWrite(callCount);
tests\Shared\TestDashboardTelemetrySender.cs (1)
23ContextChannel.Writer.TryWrite(context);
Aspire.Hosting (13)
ApplicationModel\ResourceLoggerService.cs (3)
240channel.Writer.TryWrite(new(name, hasSubscribers)); 322channel.Writer.TryWrite(logLines); 465void Log(LogEntry log) => channel.Writer.TryWrite(log);
ApplicationModel\ResourceNotificationService.cs (1)
805channel.Writer.TryWrite(resourceEvent);
ApplicationModel\TerminalService.cs (2)
435if (channel.Writer.TryWrite(change)) 465channel.Writer.TryWrite(new TerminalSnapshot(snapshot, activatedTerminalId));
Backchannel\BackchannelLoggerProvider.cs (1)
61subscriber.Writer.TryWrite(entry);
Dcp\DcpResourceWatcher.cs (2)
169_logInformationChannel.Writer.TryWrite(new(subscribers.Name, LogsAvailable: null, subscribers.AnySubscribers, ShouldStartStream: true)); 417_logInformationChannel.Writer.TryWrite(new(resource.Metadata.Name, LogsAvailable: true, HasSubscribers: null, ShouldStartStream: shouldStartStream));
Dcp\ResourceLogSource.cs (1)
91var succeeded = channel.Writer.TryWrite(new ResourceLogEntry(line, lineIsError, timestamp, rawContent));
Devcontainers\DevcontainerSettingsWriter.cs (1)
51_portUpdates.Writer.TryWrite(new PortForwardEntry(url, port, protocol, label, openBrowser));
InteractionService.cs (1)
694channel.Writer.TryWrite(resourceEvent);
Pipelines\PipelineActivityReporter.cs (1)
205ActivityItemUpdated.Writer.TryWrite(state);
Aspire.Hosting.Azure.Tests (5)
tests\Shared\TestInteractionService.cs (5)
46Interactions.Writer.TryWrite(data); 54Interactions.Writer.TryWrite(data); 69Interactions.Writer.TryWrite(data); 76Interactions.Writer.TryWrite(data); 112Interactions.Writer.TryWrite(data);
Aspire.Hosting.Browsers.Tests (5)
tests\Shared\TestInteractionService.cs (5)
46Interactions.Writer.TryWrite(data); 54Interactions.Writer.TryWrite(data); 69Interactions.Writer.TryWrite(data); 76Interactions.Writer.TryWrite(data); 112Interactions.Writer.TryWrite(data);
Aspire.Hosting.DevTunnels.Tests (5)
tests\Shared\TestInteractionService.cs (5)
46Interactions.Writer.TryWrite(data); 54Interactions.Writer.TryWrite(data); 69Interactions.Writer.TryWrite(data); 76Interactions.Writer.TryWrite(data); 112Interactions.Writer.TryWrite(data);
Aspire.Hosting.Foundry (1)
FoundryExtensions.cs (1)
490progress => progressChannel.Writer.TryWrite(progress),
Aspire.Hosting.RemoteHost.Tests (5)
tests\Shared\TestInteractionService.cs (5)
46Interactions.Writer.TryWrite(data); 54Interactions.Writer.TryWrite(data); 69Interactions.Writer.TryWrite(data); 76Interactions.Writer.TryWrite(data); 112Interactions.Writer.TryWrite(data);
Aspire.Hosting.Tests (31)
Cli\CliOrphanDetectorTests.cs (2)
155Assert.True(processRunningChannel.Writer.TryWrite(++processRunningCallCounter)); 226Assert.True(processRunningChannel.Writer.TryWrite(++processRunningCallCounter));
Dashboard\DashboardEventHandlersTests.cs (2)
43testSink.MessageLogged += c => logChannel.Writer.TryWrite(c); 96testSink.MessageLogged += c => logChannel.Writer.TryWrite(c);
Dashboard\DashboardServiceTests.cs (2)
1738sink.MessageLogged += log => logs.Writer.TryWrite(log); 1818sink.MessageLogged += log => logs.Writer.TryWrite(log);
Dcp\DcpExecutorTests.cs (10)
219endpointEventsProcessed.Writer.TryWrite(true); 1944if (!logStreamPipesChannel.Writer.TryWrite((logStreamType, s))) 2542followStdErrPipeChannel.Writer.TryWrite(pipe); 3015changes.Writer.TryWrite(context); 3083changes.Writer.TryWrite(context); 4482allocatedPortChannel.Writer.TryWrite(allocatedEndpoint.Port); 4494connectionStringAvailableChannel.Writer.TryWrite(context.Resource); 4552connectionStringAvailableChannel.Writer.TryWrite(context.Resource); 4636resolvedUrlChannel.Writer.TryWrite(url); 4678resolvedUrlChannel.Writer.TryWrite(url);
Dcp\TestKubernetesService.cs (6)
145c.Writer.TryWrite((WatchEventType.Added, Copy(res))); 148c.Writer.TryWrite((WatchEventType.Modified, Copy(modifiedResource))); 171c.Writer.TryWrite((WatchEventType.Modified, Copy(resource))); 186c.Writer.TryWrite((eventType, Copy(resource))); 217c.Writer.TryWrite((WatchEventType.Added, Copy(res))); 324chan.Writer.TryWrite((WatchEventType.Added, Copy(res)));
Health\ResourceHealthCheckServiceTests.cs (1)
153channel.Writer.TryWrite(@event);
ResourceLoggerServiceTests.cs (3)
264consoleLogsChannel0.Writer.TryWrite([LogEntry.Create(timestamp: null, logMessage: "instance0!", isErrorMessage: false)]); 268consoleLogsChannel1.Writer.TryWrite([LogEntry.Create(timestamp: null, logMessage: "instance1!", isErrorMessage: false)]); 483consoleLogsChannel.Writer.TryWrite([CreateLogEntry("dcp-snapshot-log")]);
tests\Shared\TestInteractionService.cs (5)
46Interactions.Writer.TryWrite(data); 54Interactions.Writer.TryWrite(data); 69Interactions.Writer.TryWrite(data); 76Interactions.Writer.TryWrite(data); 112Interactions.Writer.TryWrite(data);
Aspire.Hosting.TestUtilities (2)
Utils\Grpc\TestAsyncStreamReader.cs (1)
24if (!_channel.Writer.TryWrite(message))
Utils\Grpc\TestServerStreamWriter.cs (1)
58if (!_channel.Writer.TryWrite(message))
Aspire.Tray.Tests (5)
Helpers\TestAppHostClient.cs (5)
25if (!_snapshots.Writer.TryWrite(snapshot)) 54_started.Writer.TryWrite(id); 62_finished.Writer.TryWrite(id); 76_starting.Writer.TryWrite(appHostPath); 84_finishedStarts.Writer.TryWrite(appHostPath);
dotnet-aot (1)
parent\dotnet\Commands\Test\MTP\TestApplicationActionQueue.cs (1)
86if (!_channel.Writer.TryWrite(testApplication))
dotnet-watch (1)
UI\SpectreBuildParametersSelectionPrompt.cs (1)
125=> _channel.Writer.TryWrite(key);
GenerateDocumentationAndConfigFiles (2)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
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.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)
146while (!_channel.Writer.TryWrite(item))
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
214_waitForAck.Writer.TryWrite(newCount);
Microsoft.AspNetCore.SignalR.Core (3)
Internal\ChannelBasedSemaphore.cs (2)
20_channel.Writer.TryWrite(1); 37if (!_channel.Writer.TryWrite(1))
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
214_waitForAck.Writer.TryWrite(newCount);
Microsoft.Build.Tasks.Core (4)
AssemblyDependency\Node\RarNodeBuildEngine.cs (4)
152_ = _eventCountChannel.Writer.TryWrite(_pendingCount); 157_ = _eventCountChannel.Writer.TryWrite(0); 168_ = _eventChannel.Writer.TryWrite(e); 174_ = _eventCountChannel.Writer.TryWrite(_pendingCount);
Microsoft.CodeAnalysis.Analyzers (2)
src\roslyn\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\roslyn\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\roslyn\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\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.Workspaces (2)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
Microsoft.DotNet.HotReload.Watch (1)
Aspire\AspireServiceFactory.cs (1)
135var writeResult = outputChannel.Writer.TryWrite(line);
Microsoft.Extensions.ServiceDiscovery.Tests (1)
ServiceEndpointResolverTests.cs (1)
267watcher.OnEndpointsUpdated = result => channel.Writer.TryWrite(result);
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\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
269args.channel.Writer.TryWrite(item); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false);
Stress.ApiService (1)
Program.cs (1)
304channel.Writer.TryWrite($"Logged {logCount} messages.");
System.IO.FileSystem.Watcher (2)
System\IO\FileSystemWatcher.Linux.cs (2)
1227_eventQueue.Writer.TryWrite(ev); 1236_eventQueue.Writer.TryWrite(WatcherEvent.Error(exception));
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
1210if (!_writeChannel.Writer.TryWrite(writeEntry))
System.Net.Quic (4)
System\Net\Quic\QuicConnection.cs (1)
715if (!_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))