5 writes to Writer
System.Threading.Channels (5)
System\Threading\Channels\BoundedChannel.cs (1)
65Writer = new BoundedChannelWriter(this);
System\Threading\Channels\RendezvousChannel.cs (1)
56Writer = new RendezvousChannelWriter(this);
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
48Writer = new UnboundedChannelWriter(this);
System\Threading\Channels\UnboundedChannel.cs (1)
42Writer = new UnboundedChannelWriter(this);
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
49Writer = new UnboundedPrioritizedChannelWriter(this);
428 references to Writer
aspire (22)
Interaction\ExtensionInteractionService.cs (22)
66var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(statusText.RemoveSpectreFormatting(), _cancellationToken)); 70result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken)); 77var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(statusText.RemoveSpectreFormatting(), _cancellationToken)); 81result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.ShowStatusAsync(null, _cancellationToken)); 91await _extensionTaskChannel.Writer.WriteAsync(async () => 139await _extensionTaskChannel.Writer.WriteAsync(async () => 168await _extensionTaskChannel.Writer.WriteAsync(async () => 197await _extensionTaskChannel.Writer.WriteAsync(async () => 221var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayIncompatibleVersionErrorAsync(ex.RequiredCapability, appHostHostingSdkVersion, _cancellationToken)); 229var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayErrorAsync(errorMessage.RemoveSpectreFormatting(), _cancellationToken)); 236var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayMessageAsync(emoji, message.RemoveSpectreFormatting(), _cancellationToken)); 243var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplaySuccessAsync(message.RemoveSpectreFormatting(), _cancellationToken)); 250var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplaySubtleMessageAsync(message.RemoveSpectreFormatting(), _cancellationToken)); 257var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayDashboardUrlsAsync(dashboardUrls, _cancellationToken)); 263var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayLinesAsync(lines.Select(line => new DisplayLineState(line.Stream.RemoveSpectreFormatting(), line.Line.RemoveSpectreFormatting())), _cancellationToken)); 270var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayCancellationMessageAsync(_cancellationToken)); 277var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayEmptyLineAsync(_cancellationToken)); 284var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.OpenEditorAsync(path, _cancellationToken)); 290var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.DisplayPlainTextAsync(text, _cancellationToken)); 299var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.LogMessageAsync(LogLevel.Information, markdown, _cancellationToken)); 311var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.LogMessageAsync(logLevel, message.RemoveSpectreFormatting(), _cancellationToken)); 327var result = _extensionTaskChannel.Writer.TryWrite(() => Backchannel.NotifyAppHostStartupCompletedAsync(_cancellationToken));
Aspire.Cli.Tests (8)
Hosting\CliOrphanDetectorTests.cs (8)
40var lifetime = new HostLifetimeStub(() => stopSignalChannel.Writer.TryWrite(true)); 66var lifetime = new HostLifetimeStub(() => stopSignalChannel.Writer.TryWrite(true)); 87var lifetime = new HostLifetimeStub(() => stopSignalChannel.Writer.TryWrite(true)); 113var lifetime = new HostLifetimeStub(() => stopSignalChannel.Writer.TryWrite(true)); 118Assert.True(processRunningChannel.Writer.TryWrite(++processRunningCallCounter)); 154var lifetime = new HostLifetimeStub(() => stopSignalChannel.Writer.TryWrite(true)); 179var lifetime = new HostLifetimeStub(() => stopSignalChannel.Writer.TryWrite(true)); 184Assert.True(processRunningChannel.Writer.TryWrite(++processRunningCallCounter));
Aspire.Components.Common.TestUtilities (2)
ActivityNotifier.cs (2)
36_activityChannel.Writer.TryWrite(data); 51_activityChannel.Writer.TryComplete();
Aspire.Confluent.Kafka (1)
MetricsChannel.cs (1)
24public ChannelWriter<string> Writer => _channel.Writer;
Aspire.Dashboard (11)
Components\Pages\ConsoleLogs.razor.cs (3)
781_logEntryChannel.Writer.TryWrite(new LogEntryToWrite(LogEntry.CreatePause(GetResourceName(subscription.Resource), priorPause.Start, priorPause.End), LineNumber: null)); 801_logEntryChannel.Writer.TryWrite(new LogEntryToWrite(logEntry, lineNumber)); 988_logEntryChannel.Writer.TryWrite(new LogEntryToWrite(LogEntry.CreatePause(GetResourceName(subscription.Resource), timestamp), LineNumber: null));
ServiceClient\DashboardClient.cs (5)
422channel.Writer.TryWrite(changes); 495channel.Writer.TryWrite(response); 531await _incomingInteractionChannel.Writer.WriteAsync(request, cancellationToken).ConfigureAwait(false); 676channel.Writer.TryWrite(CreateLogLines(response.LogLines)); 681channel.Writer.TryComplete();
Telemetry\DashboardTelemetrySender.cs (3)
106_channel.Writer.TryComplete(); 169_channel.Writer.TryWrite((context, requestFunc)); 174_channel.Writer.TryComplete();
Aspire.Dashboard.Components.Tests (33)
Interactions\InteractionsProviderTests.cs (10)
101await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 148await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 167await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 207await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 273await interactionsChannel.Writer.WriteAsync(response); 332await interactionsChannel.Writer.WriteAsync(response); 352await interactionsChannel.Writer.WriteAsync(response); 405await interactionsChannel.Writer.WriteAsync(response); 425await interactionsChannel.Writer.WriteAsync(response); 489await interactionsChannel.Writer.WriteAsync(response);
Pages\ConsoleLogsTests.cs (18)
56subscribedResourceNamesChannel.Writer.TryWrite(name); 107subscribedResourceNamesChannel.Writer.TryWrite(name); 139consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Test content", IsErrorMessage: false)]); 140consoleLogsChannel.Writer.Complete(); 174subscribedResourceNamesChannel.Writer.Complete(); 329consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Hello world", IsErrorMessage: false)]); 377consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!")); 428consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!")); 470consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]); 486consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]); 530consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]); 542consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]); 598resourceChannel.Writer.TryWrite([ 665resourceCommandChannel.Writer.TryWrite(new ResourceCommandResponseViewModel 724consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, pauseContent, IsErrorMessage: false)]); 725consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(2, pauseContent, IsErrorMessage: false)]); 726consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(3, pauseContent, IsErrorMessage: false)]); 768consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(4, resumeContent, IsErrorMessage: false)]);
Pages\ResourcesTests.cs (2)
70channel.Writer.TryWrite([ 341channel.Writer.TryWrite(new[]
tests\Shared\TestDashboardClient.cs (1)
137await _sendInteractionUpdateChannel.Writer.WriteAsync(request, cancellationToken);
tests\Shared\TestDashboardTelemetrySender.cs (2)
23ContextChannel.Writer.TryWrite(context); 28ContextChannel.Writer.Complete();
Aspire.Dashboard.Tests (25)
ChannelExtensionsTests.cs (11)
21channel.Writer.TryWrite(["a", "b", "c"]); 45channel.Writer.TryWrite(["a", "b", "c"]); 71channel.Writer.TryWrite(["a", "b", "c"]); 80resultChannel.Writer.TryWrite(batch); 85resultChannel.Writer.Complete(); 94channel.Writer.TryWrite(["d", "e", "f"]); 102channel.Writer.Complete(); 115channel.Writer.TryWrite(["a", "b", "c"]); 124resultChannel.Writer.TryWrite(batch); 129resultChannel.Writer.Complete(); 138channel.Writer.TryWrite(["d", "e", "f"]);
Integration\DashboardClientAuthTests.cs (1)
165testCalls.ResourceInformationCallsChannel.Writer.TryWrite(new ReceivedCallInfo<ApplicationInformationRequest>(request, context.RequestHeaders));
Model\AIAssistant\AIContextProviderTests.cs (2)
86changeChannel.Writer.TryWrite(provider.GetContext()); 114changeChannel.Writer.Complete();
Model\AIAssistant\AssistantChatDataContextTests.cs (2)
194consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(i + 1, line, IsErrorMessage: false)]); 196consoleLogsChannel.Writer.Complete();
ResourceOutgoingPeerResolverTests.cs (5)
138await resultChannel.Writer.WriteAsync(++changeCount); 156await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8080, state: KnownResourceState.Starting))); 164await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Starting))); 172await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Running))); 176resultChannel.Writer.Complete();
TelemetryRepositoryTests\LogTests.cs (1)
724resultChannel.Writer.TryWrite(callCount);
tests\Shared\TestDashboardClient.cs (1)
137await _sendInteractionUpdateChannel.Writer.WriteAsync(request, cancellationToken);
tests\Shared\TestDashboardTelemetrySender.cs (2)
23ContextChannel.Writer.TryWrite(context); 28ContextChannel.Writer.Complete();
Aspire.Hosting (29)
ApplicationModel\ResourceLoggerService.cs (6)
231channel.Writer.TryWrite(new(name, hasSubscribers)); 302channel.Writer.TryWrite(logLines); 314channel.Writer.Complete(); 421using var _ = _logStreamCts.Token.Register(() => channel.Writer.TryComplete()); 424void Log(LogEntry log) => channel.Writer.TryWrite(log); 462channel.Writer.TryComplete();
ApplicationModel\ResourceNotificationService.cs (2)
529channel.Writer.TryWrite(resourceEvent); 577channel.Writer.TryComplete();
Backchannel\BackchannelLoggerProvider.cs (2)
58_channel.Writer.Complete(); 87channel.Writer.TryWrite(entry);
Dashboard\ResourcePublisher.cs (1)
106await channel.Writer.WriteAsync(new(changeType, snapshot), cancellationToken).ConfigureAwait(false);
Dcp\DcpExecutor.cs (2)
263_logInformationChannel.Writer.TryWrite(new(subscribers.Name, LogsAvailable: null, subscribers.AnySubscribers)); 408_logInformationChannel.Writer.TryWrite(new(resource.Metadata.Name, LogsAvailable: true, HasSubscribers: null));
Dcp\ResourceLogSource.cs (4)
64channel.Writer.TryComplete(); 94var succeeded = channel.Writer.TryWrite((line, isError)); 98channel.Writer.TryComplete(); 110channel.Writer.TryComplete(ex);
Devcontainers\DevcontainerSettingsWriter.cs (2)
51_portUpdates.Writer.TryWrite(new PortForwardEntry(url, port, protocol, label, openBrowser)); 273_portUpdates.Writer.TryComplete();
InteractionService.cs (2)
432channel.Writer.TryWrite(resourceEvent); 462channel.Writer.TryComplete();
Publishing\PublishingActivityReporter.cs (8)
58await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 94await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 124await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 156await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 195await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 221await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 300await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false); 331await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Azure.Tests (2)
tests\Shared\TestInteractionService.cs (2)
36Interactions.Writer.TryWrite(data); 51Interactions.Writer.TryWrite(data);
Aspire.Hosting.Tests (34)
Dashboard\DashboardLifecycleHookTests.cs (1)
38testSink.MessageLogged += c => logChannel.Writer.TryWrite(c);
Dashboard\DashboardServiceTests.cs (2)
74await getConsoleLogsChannel.Writer.WriteAsync([LogEntry.Create(null, "Test3", isErrorMessage: false)]); 82getConsoleLogsChannel.Writer.TryComplete();
Dcp\DcpExecutorTests.cs (3)
78await channel.Writer.WriteAsync(context.DcpResourceName); 574if (!logStreamPipesChannel.Writer.TryWrite((logStreamType, s))) 768logStreamPipesChannel.Writer.Complete();
Dcp\TestKubernetesService.cs (4)
86c.Writer.TryWrite((WatchEventType.Added, res)); 99c.Writer.TryWrite((WatchEventType.Modified, resource)); 141chan.Writer.TryWrite((WatchEventType.Added, res)); 241_ = c.Writer.TryComplete();
DistributedApplicationTests.cs (1)
644await beforeResourceStartedEvents.Writer.WriteAsync(e, ct);
Health\ResourceHealthCheckServiceTests.cs (2)
152channel.Writer.TryWrite(@event); 299await channel.Writer.WriteAsync(timeProvider.GetUtcNow());
InteractionServiceTests.cs (3)
128await updates.Writer.WriteAsync(interaction); 722await updates.Writer.WriteAsync(interaction); 775await updates.Writer.WriteAsync(interaction);
ResourceCommandServiceTests.cs (4)
90await commandResourcesChannel.Writer.WriteAsync(e.ResourceName); 99commandResourcesChannel.Writer.Complete(); 126await commandResourcesChannel.Writer.WriteAsync(e.ResourceName); 136commandResourcesChannel.Writer.Complete();
ResourceLoggerServiceTests.cs (4)
262consoleLogsChannel0.Writer.TryWrite([LogEntry.Create(timestamp: null, logMessage: "instance0!", isErrorMessage: false)]); 263consoleLogsChannel0.Writer.Complete(); 266consoleLogsChannel1.Writer.TryWrite([LogEntry.Create(timestamp: null, logMessage: "instance1!", isErrorMessage: false)]); 267consoleLogsChannel1.Writer.Complete();
tests\Shared\TestInteractionService.cs (2)
36Interactions.Writer.TryWrite(data); 51Interactions.Writer.TryWrite(data);
Utils\Grpc\TestAsyncStreamReader.cs (2)
24if (!_channel.Writer.TryWrite(message)) 32_channel.Writer.Complete(ex);
Utils\Grpc\TestServerStreamWriter.cs (2)
25_channel.Writer.Complete(ex); 52if (!_channel.Writer.TryWrite(message))
VersionChecking\VersionCheckServiceTests.cs (4)
94interactionService.Interactions.Writer.Complete(); 178interactionService.Interactions.Writer.Complete(); 209interactionService.Interactions.Writer.Complete(); 238interactionService.Interactions.Writer.Complete();
ClientSample (5)
UploadSample.cs (5)
49await channel.Writer.WriteAsync(c.ToString()); 52channel.Writer.TryComplete(); 62_ = WriteItemsAsync(channel_one.Writer, new[] { 2, 2, 3 }); 63_ = WriteItemsAsync(channel_two.Writer, new[] { -2, 5, 3 }); 91await channel.Writer.WriteAsync(phrase);
GenerateDocumentationAndConfigFiles (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 336static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)), 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
InMemory.FunctionalTests (9)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (7)
296var success = _http3TestBase._serverReceivedSettings.Writer.TryWrite( 410MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 435MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 454MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 1049ToServerAcceptQueue.Writer.TryComplete(); 1050ToClientAcceptQueue.Writer.TryComplete(); 1080ToClientAcceptQueue.Writer.WriteAsync(stream);
TestTransport\InMemoryTransportFactory.cs (2)
21_acceptQueue.Writer.TryWrite(connection); 52_acceptQueue.Writer.TryComplete();
Metrics (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Metrics.Legacy (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.AspNetCore.ConcurrencyLimiter.Tests (2)
src\Shared\EventSource.Testing\TestCounterListener.cs (2)
62var writer = _counters[counter].Writer; 72item.Value.Writer.TryComplete();
Microsoft.AspNetCore.Hosting.Tests (2)
src\Shared\EventSource.Testing\TestCounterListener.cs (2)
62var writer = _counters[counter].Writer; 72item.Value.Writer.TryComplete();
Microsoft.AspNetCore.Http.Connections.Tests (2)
TestWebSocketConnectionFeature.cs (2)
43var clientSocket = new WebSocketChannel(serverToClient.Reader, clientToServer.Writer, _sync); 44var serverSocket = new WebSocketChannel(clientToServer.Reader, serverToClient.Writer, _sync);
Microsoft.AspNetCore.Server.Kestrel.Core (5)
Internal\Http2\Http2FrameWriter.cs (2)
166if (!_channel.Writer.TryWrite(producer)) 453_channel.Writer.TryComplete();
Internal\WebTransport\WebTransportSession.cs (3)
88_pendingStreams.Writer.Complete(); 119_pendingStreams.Writer.Complete(); 155if (!addedToOpenStreams || !_pendingStreams.Writer.TryWrite(stream))
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (7)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (7)
296var success = _http3TestBase._serverReceivedSettings.Writer.TryWrite( 410MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 435MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 454MultiplexedConnectionContext.ToServerAcceptQueue.Writer.TryWrite(stream.StreamContext); 1049ToServerAcceptQueue.Writer.TryComplete(); 1050ToClientAcceptQueue.Writer.TryComplete(); 1080ToClientAcceptQueue.Writer.WriteAsync(stream);
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (4)
Internal\NamedPipeConnectionListener.cs (4)
89_acceptedQueue.Writer.TryComplete(); 93_acceptedQueue.Writer.TryComplete(ex); 119while (!_acceptedQueue.Writer.TryWrite(connection)) 121if (!await _acceptedQueue.Writer.WaitToWriteAsync(_listeningToken))
Microsoft.AspNetCore.SignalR.Client.Core (13)
HubConnection.cs (2)
1659closeMessage = await ProcessMessagesAsync(message, connectionState, invocationMessageChannel.Writer).ConfigureAwait(false); 1711invocationMessageChannel.Writer.TryComplete();
HubConnectionExtensions.StreamAsChannelAsync.cs (4)
295while (!outputChannel.Writer.TryWrite((TResult)item!)) 297if (!await outputChannel.Writer.WaitToWriteAsync().ConfigureAwait(false)) 308outputChannel.Writer.TryComplete(ex); 313outputChannel.Writer.TryComplete();
Internal\InvocationRequest.cs (6)
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); 139while (!_channel.Writer.TryWrite(item)) 141if (!await _channel.Writer.WaitToWriteAsync().ConfigureAwait(false)) 163_channel.Writer.TryComplete(new OperationCanceledException());
src\SignalR\common\Shared\MessageBuffer.cs (1)
207_waitForAck.Writer.TryWrite(newCount);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (18)
HubConnectionTests.cs (5)
802await channelWriter.Writer.WriteAsync("1").AsTask().DefaultTimeout(); 804await channelWriter.Writer.WriteAsync("2").AsTask().DefaultTimeout(); 806channelWriter.Writer.Complete(); 2945_taskQueue.Writer.TryWrite((d, state)); 2951_taskQueue.Writer.Complete();
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);
Hubs.cs (6)
233await channel.Writer.WriteAsync(i); 237channel.Writer.TryComplete(); 261await output.Writer.WriteAsync(item); 267output.Writer.TryComplete(); 285await output.Writer.WriteAsync(item); 291output.Writer.TryComplete();
Microsoft.AspNetCore.SignalR.Client.Tests (9)
HubConnectionTests.cs (9)
448await channel.Writer.WriteAsync(number).AsTask().DefaultTimeout(); 456channel.Writer.TryComplete(); 489await channel.Writer.WriteAsync(item); 520await channel.Writer.WriteAsync(item); 528channel.Writer.TryComplete(); 565await channel.Writer.WriteAsync(number); 592channel.Writer.Complete(new Exception("error from client")); 685await channel.Writer.WriteAsync(5); 686await channel.Writer.WriteAsync(10);
Microsoft.AspNetCore.SignalR.Core (5)
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);
StreamTracker.cs (2)
134return _channel.Writer.WriteAsync((T?)o).AsTask(); 139_channel.Writer.TryComplete(ex);
Microsoft.AspNetCore.SignalR.Microbenchmarks (5)
DefaultHubDispatcherBenchmark.cs (5)
137channel.Writer.Complete(); 145channel.Writer.Complete(); 153channel.Writer.Complete(); 166await channel.Writer.WriteAsync(i); 168channel.Writer.Complete();
Microsoft.AspNetCore.SignalR.Tests (35)
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)
HubConnectionHandlerTestUtils\Hubs.cs (15)
294_ = ChannelFunc(channel.Writer, source); 710await channel.Writer.WriteAsync(i.ToString(CultureInfo.InvariantCulture)); 712channel.Writer.Complete(); 779channel.Writer.TryComplete(new Exception("Exception from channel")); 786channel.Writer.TryComplete(new ChannelClosedException("ChannelClosedException from channel")); 793channel.Writer.TryComplete(new ChannelClosedException(new Exception("ChannelClosedException from channel"))); 822await output.Writer.WriteAsync("echo:" + item); 826output.Writer.TryComplete(); 1041channel.Writer.TryComplete(); 1056channel.Writer.TryComplete(); 1071channel.Writer.TryComplete(); 1085channel.Writer.TryComplete(); 1101channel.Writer.TryComplete(); 1138await channel.Writer.WriteAsync(i); 1142channel.Writer.TryComplete();
NativeAotTests.cs (12)
81await channel.Writer.WriteAsync("some data"); 82await channel.Writer.WriteAsync("some more data"); 83await channel.Writer.WriteAsync("even more data"); 84channel.Writer.Complete(); 113await channelShorts.Writer.WriteAsync(9); 114await channelShorts.Writer.WriteAsync(8); 115await channelShorts.Writer.WriteAsync(7); 116channelShorts.Writer.Complete(); 255await output.Writer.WriteAsync("echo:" + item); 258output.Writer.TryComplete(); 289await output.Writer.WriteAsync(item); 292output.Writer.TryComplete();
Microsoft.CodeAnalysis.Analyzers (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.AnalyzerUtilities (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.BannedApiAnalyzers (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.CodeStyle (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.PublicApiAnalyzers (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.ResxSourceGenerator (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.Threading.Package (5)
ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 336static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)), 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
Microsoft.CodeAnalysis.Workspaces (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 336static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)), 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.Extensions.AI (2)
ChatCompletion\AnonymousDelegatingChatClient.cs (2)
146await updates.Writer.WriteAsync(update, cancellationToken); 157_ = updates.Writer.TryComplete(error);
Microsoft.ML.Data (1)
Transforms\RowShufflingTransformer.cs (1)
557bool retval = target.Writer.TryWrite(item);
Microsoft.ML.Sweeper (2)
AsyncSweeper.cs (2)
224_paramChannel.Writer.Complete(); 229_paramChannel.Writer.TryWrite(new ParameterSetWithId(_numGenerated++, paramSet));
Roslyn.Diagnostics.Analyzers (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
SignalR.Client.FunctionalTestApp (5)
TestHub.cs (5)
63channel.Writer.TryWrite("a"); 64channel.Writer.TryWrite("b"); 65channel.Writer.TryWrite("c"); 66channel.Writer.Complete(); 101channel.Writer.Complete();
SignalRSamples (8)
Hubs\Streaming.cs (2)
38await channel.Writer.WriteAsync(i); 42channel.Writer.TryComplete();
Hubs\UploadHub.cs (2)
74await output.Writer.WriteAsync("echo:" + item); 77output.Writer.Complete();
ObservableExtensions.cs (4)
29value => channel.Writer.TryWrite(value), 30error => channel.Writer.TryComplete(error), 31() => channel.Writer.TryComplete()); 32var abortRegistration = connectionAborted.Register(() => channel.Writer.TryComplete());
Stress.ApiService (4)
ProducerConsumer.cs (2)
63await _channel.Writer.WriteAsync(data); 65_channel.Writer.Complete();
Program.cs (2)
260channel.Writer.TryWrite($"Logged {logCount} messages."); 266channel.Writer.Complete();
System.Net.Http (2)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)
1190if (!_writeChannel.Writer.TryWrite(writeEntry)) 1862bool completed = _writeChannel.Writer.TryComplete();
System.Net.Quic (9)
System\Net\Quic\QuicConnection.cs (5)
661_acceptQueue.Writer.TryComplete(exception); 672_acceptQueue.Writer.TryComplete(exception); 686_acceptQueue.Writer.TryComplete(exception); 712if (!_acceptQueue.Writer.TryWrite(stream)) 863_acceptQueue.Writer.TryComplete(ExceptionDispatchInfo.SetCurrentStackTrace(new ObjectDisposedException(GetType().FullName)));
System\Net\Quic\QuicListener.cs (4)
248if (!_acceptQueue.Writer.TryWrite(connection)) 280if (!_acceptQueue.Writer.TryWrite(ex)) 315if (!_acceptQueue.Writer.TryWrite( 432_acceptQueue.Writer.TryComplete(ExceptionDispatchInfo.SetCurrentStackTrace(new ObjectDisposedException(GetType().FullName)));
System.Threading.Channels (2)
System\Threading\Channels\Channel_2.cs (1)
26public static implicit operator ChannelWriter<TWrite>(Channel<TWrite, TRead> channel) => channel.Writer;
System\Threading\Channels\RendezvousChannel.cs (1)
487$"{((RendezvousChannelReader)Reader).DebuggerDisplay}, {((RendezvousChannelWriter)Writer).DebuggerDisplay}";
Test.Utilities (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 336static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)), 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
TestDiscoveryWorker (2)
Program.cs (2)
142_channel.Writer.Complete(); 152if (!_channel.Writer.TryWrite(fullName))
Text.Analyzers (7)
src\Dependencies\Threading\ProducerConsumer.cs (5)
269args.channel.Writer.TryWrite(item); 276channel.Writer, 339() => channel.Writer.TryComplete(new OperationCanceledException(cancellationToken))); 367await produceItems(item => channel.Writer.TryWrite(item), args, cancellationToken).ConfigureAwait(false); 370channel.Writer,
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
54tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 81static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),