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);
573 references to Writer
aspire (52)
Backchannel\AuxiliaryBackchannelMonitor.cs (3)
89void QueueConnectionChange() => connectionChanges.Writer.TryWrite(true); 117connectionChanges.Writer.TryComplete(); 138connectionChanges.Writer.TryComplete();
Backchannel\ResourceSnapshotWatcher.cs (4)
74_updateSignal?.Writer.TryComplete(); 92_updateSignal?.Writer.TryComplete(); 97_updateSignal?.Writer.TryComplete(ex); 223_updateSignal?.Writer.TryWrite(true);
Backchannel\TrayWatchStream.cs (3)
165updates.Writer.TryWrite(update); 179updates.Writer.TryComplete(); 242connection, host, () => healthChanges.Writer.TryWrite(true), logger, token));
Commands\PsCommand.cs (2)
247await updates.Writer.WriteAsync(new ConnectionsUpdate(connections), followCancellationToken).ConfigureAwait(false); 260updates.Writer.TryComplete();
Diagnostics\FileLoggerProvider.cs (4)
209if (_channel.Writer.TryWrite(message)) 225if (!_channel.Writer.WaitToWriteAsync().AsTask().GetAwaiter().GetResult()) 231_channel.Writer.TryWrite(message); 269_channel?.Writer.TryComplete();
Interaction\ExtensionInteractionService.cs (35)
78await _extensionTaskChannel.Writer.WriteAsync(() => 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)); 160await _extensionTaskChannel.Writer.WriteAsync(async () => 221await _extensionTaskChannel.Writer.WriteAsync(async () => 283await _extensionTaskChannel.Writer.WriteAsync(async () => 321await _extensionTaskChannel.Writer.WriteAsync(async () => 360await _extensionTaskChannel.Writer.WriteAsync(async () => 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)); 727_extensionTaskChannel.Writer.TryComplete();
Projects\ProjectLocator.cs (1)
200var discoveryTask = CompleteFindAppHostProjectsStreamAsync(searchDirectory, scope, channel.Writer, onDirectoryEnumerated, discoveryCancellationTokenSource.Token);
aspire-tray (1)
NativeSmokeHarness.cs (1)
428=> Require(_snapshots.Writer.TryWrite(snapshot), "The smoke snapshot channel is closed.");
Aspire.Cli.Tests (39)
Backchannel\ResourceSnapshotWatcherTests.cs (3)
569await source.Writer.WriteAsync(firstSnapshot); 582await source.Writer.WriteAsync(new ResourceSnapshot 596source.Writer.TryComplete();
Backchannel\TrayWatchStreamTests.cs (29)
116snapshots.Writer.TryWrite([second, first]); 126snapshots.Writer.TryWrite([second]); 130snapshots.Writer.TryWrite([]); 457messages.Writer.TryWrite(Deserialize(json)); 579batches.Writer.TryWrite(count); 639snapshots.Writer.TryWrite(hung); 642messages.Writer.TryWrite(Deserialize(json)); 667snapshots.Writer.TryWrite(saturateSlots ? [newcomer] : [hung[0], healthy, newcomer]); 743snapshots.Writer.TryWrite([connection]); 748messages.Writer.TryWrite(Deserialize(json)); 758resourceUpdates.Writer.TryWrite(new() { Name = "api", State = "Running", HealthStatus = "Healthy", Version = 2 }); 761resourceUpdates.Writer.TryWrite(new() { Name = "cache", State = "Running", HealthStatus = "Degraded", Version = 2 }); 764resourceUpdates.Writer.TryWrite(new() { Name = "cache", State = "Running", HealthStatus = "Unhealthy", Version = 3 }); 767resourceUpdates.Writer.TryWrite(new() { Name = "cache", State = "Running", HealthStatus = "Healthy", Version = 4 }); 770resourceUpdates.Writer.TryWrite(new() { Name = "api", State = "Running", HealthStatus = "Unhealthy", Version = 1 }); 771resourceUpdates.Writer.TryWrite(new() { Name = "cache", State = "FailedToStart", Version = 5 }); 774resourceUpdates.Writer.TryWrite(new() { Name = "cache", State = "FailedToStart", IsHidden = true, Version = 6 }); 777resourceUpdates.Writer.TryComplete(); 832messages.Writer.TryWrite(Deserialize(json)); 839resourceUpdates.Writer.TryComplete(fails ? new IOException("Resource stream failed.") : null); 871snapshots.Writer.TryWrite([initial]); 875messages.Writer.TryWrite(Deserialize(json)); 885snapshots.Writer.TryWrite([]); 890snapshots.Writer.TryWrite([replacement]); 944snapshots.Writer.TryWrite([initial]); 951messages.Writer.TryWrite(Deserialize(json)); 960snapshots.Writer.TryWrite([]); 963snapshots.Writer.TryWrite([replacement]); 970snapshots.Writer.TryWrite([replacement]);
Commands\AgentMcpCommandTests.cs (4)
1053notificationChannel.Writer.TryWrite(notification); 1250notificationChannel.Writer.TryWrite(notification); 1310notificationChannel.Writer.TryWrite(notification); 1349notificationChannel.Writer.TryWrite(notification);
Commands\LogsCommandTests.cs (2)
1440logLines.Writer.TryWrite(line); 1481logLines.Writer.Complete();
TestServices\TestAuxiliaryBackchannelMonitor.cs (1)
68_connectionChanges.Writer.TryWrite(true);
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 (19)
Api\TelemetryApiService.cs (1)
531signal.Writer.TryWrite(true);
Components\Pages\ConsoleLogs.razor.cs (3)
836_logEntryChannel.Writer.TryWrite(pauseIntervals 860_logEntryChannel.Writer.TryWrite(logEntries); 1012_logEntryChannel.Writer.TryWrite([new LogEntryToWrite(subscription.Resource.Name, LogEntry.CreatePause(GetResourceName(subscription.Resource), timestamp), LineNumber: null)]);
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (6)
270channel.Writer.TryComplete(); 330channel.Writer.TryComplete(); 365watcher.Channel.Writer.TryWrite(span); 400watcher.Channel.Writer.TryWrite(log); 412watcher.Channel.Writer.TryComplete(); 416watcher.Channel.Writer.TryComplete();
ServiceClient\DashboardClient.cs (5)
732channel.Writer.TryWrite(changes); 809channel.Writer.TryWrite(response); 845await _incomingInteractionChannel.Writer.WriteAsync(request, cancellationToken).ConfigureAwait(false); 1024channel.Writer.TryWrite(CreateLogLines(response.LogLines)); 1029channel.Writer.TryComplete();
ServiceClient\SqliteResourceRepository.cs (4)
390channel.Writer.TryWrite(viewModelLines); 512channel.Writer.TryWrite(changes); 542channel.Writer.TryComplete(); 546channel.Writer.TryComplete();
Aspire.Dashboard.Components.Tests (137)
Controls\TerminalDisconnectedBannerTests.cs (6)
43await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, resource)]); 49await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Delete, resource)]); 124await updates.Writer.WriteAsync([ 168await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, ModelTestHelpers.CreateResource(resourceName: "shell", 172await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, ModelTestHelpers.CreateResource(resourceName: "shell", 177await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Delete, resource)]);
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.cs (14)
165await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 218await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 237await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 276await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 341await interactionsChannel.Writer.WriteAsync(response); 397await interactionsChannel.Writer.WriteAsync(response); 419await interactionsChannel.Writer.WriteAsync(response); 459await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 509await interactionsChannel.Writer.WriteAsync(response); 529await interactionsChannel.Writer.WriteAsync(response); 592await interactionsChannel.Writer.WriteAsync(response); 640await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 693await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 712await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate
Interactions\InteractionsProviderTests.Terminal.cs (12)
34shown.Writer.TryWrite((content, parameters)); 39await updates.Writer.WriteAsync(new WatchInteractionsResponseUpdate 93shown.Writer.TryWrite((content, parameters)); 98await updates.Writer.WriteAsync(new WatchInteractionsResponseUpdate 109await updates.Writer.WriteAsync(terminal); 110await updates.Writer.WriteAsync(new WatchInteractionsResponseUpdate 114await updates.Writer.WriteAsync(new WatchInteractionsResponseUpdate 124await updates.Writer.WriteAsync(queuedUpdate); 125await updates.Writer.WriteAsync(new WatchInteractionsResponseUpdate { InteractionId = 3, Complete = new InteractionComplete() }); 129await updates.Writer.WriteAsync(new WatchInteractionsResponseUpdate { InteractionId = 1, Complete = new InteractionComplete() }); 139await updates.Writer.WriteAsync(replay); 145await updates.Writer.WriteAsync(new WatchInteractionsResponseUpdate { InteractionId = 2, Complete = new InteractionComplete() });
Layout\MainLayoutResourceTerminalsTests.cs (4)
118await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, resource)]); 121await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, ModelTestHelpers.CreateResource("shell"))]); 124await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, resource)]); 127await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Delete, resource)]);
Layout\MainLayoutTerminalTests.cs (2)
133await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "old")); 152await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("new"));
Layout\TerminalDockInitializationTests.cs (4)
30OnTerminalUpdateProcessed = update => processed.Writer.TryWrite(update) 45await updates.Writer.WriteAsync(update); 57await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "first", "Renamed")); 71await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot());
Layout\TerminalDockTelemetryTests.cs (6)
42await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second")); 57await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "first")); 62await updates.Writer.WriteAsync(snapshot); 75await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "second")); 81await updates.Writer.WriteAsync(recovery); 94await updates.Writer.WriteAsync(recovery);
Layout\TerminalDockTests.cs (38)
34await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second", "third")); 47await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second", "third", "fourth")); 53await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Removed, "second")); 69await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second")); 141await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot(terminalId)); 161await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second")); 229await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second")); 232await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Added, "third")); 240await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "second")); 244await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("replacement")); 276await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second", "removed")); 283await updates.Writer.WriteAsync(recovery); 300await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Added, "later")); 323await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("replacement")); 349await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second", "third")); 404await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot(ids)); 415await updates.Writer.WriteAsync(useSnapshot 438await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second")); 450await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Removed, "first")); 468await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "first")); 471await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Removed, "first")); 481await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Added, "second")); 498await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second", "third")); 506await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Removed, "second")); 531await updates.Writer.WriteAsync(snapshot); 540await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Removed, "terminal-id")); 569await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second")); 597await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Retitled, "first", "Updated while hidden")); 603await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "second")); 638await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("terminal")); 664await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("terminal")); 691await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", terminalId)); 704await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", terminalId, "third")); 737await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "detached")); 752await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("remaining")); 778await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second")); 789await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Removed, "first")); 820await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "terminal"));
Layout\TerminalDockWindowTrackingTests.cs (6)
42await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("terminal")); 94await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("active", "inactive")); 127await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("active", "inactive")); 187started.Writer.TryWrite(true); 198await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("old-identity")); 202await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("new-identity"));
Pages\ConsoleLogsTerminalTests.cs (1)
41await logs.Writer.WriteAsync([new ResourceLogLine(1, "startup output", false)]);
Pages\ConsoleLogsTests.cs (21)
49subscribedResourceNamesChannel.Writer.TryWrite(name); 100subscribedResourceNamesChannel.Writer.TryWrite(name); 132consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Test content", IsErrorMessage: false)]); 133consoleLogsChannel.Writer.Complete(); 168subscribedResourceNamesChannel.Writer.Complete(); 359consoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Hello world", IsErrorMessage: false)]); 399liveConsoleLogsChannel.Writer.TryWrite([new ResourceLogLine(1, "Live log", IsErrorMessage: false)]); 446consoleLogsChannel.Writer.TryWrite([ 536consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!")); 587consoleLogsChannel.Writer.Complete(new InvalidOperationException("Error!")); 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 (3)
295channel.Writer.TryWrite([ 637await channel.Writer.WriteAsync([new ResourceViewModelChange( 1027channel.Writer.TryWrite(new[]
Pages\TerminalsTests.cs (4)
503await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, 510await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Delete, last)]); 524await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, ModelTestHelpers.CreateResource("first"))]); 598await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, TerminalSetupHelpers.CreateTerminalResource("added"))]);
Pages\TerminalWindowTests.cs (8)
486await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Retitled, "terminal", "Shell")); 493await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Removed, "terminal")); 513await firstUpdates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Retitled, "first", "First shell")); 517await firstUpdates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Removed, "first")); 524await secondUpdates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Retitled, "second", "Second shell")); 559await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Retitled, "first", "Stale title")); 584await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("terminal")); 587await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot());
tests\Shared\DashboardTelemetryFixture.cs (5)
49ActivityStopped = activity => ActivityChannel.Writer.TryWrite(activity) 72provider.AddProcessor(new EventLogProcessor(LogChannel.Writer)); 110ActivityChannel.Writer.TryComplete(); 111LogChannel.Writer.TryComplete(); 149LogChannel.Writer.TryWrite(TestDashboardTelemetryLog.Create(record));
tests\Shared\TestDashboardClient.cs (1)
258await _sendInteractionUpdateChannel.Writer.WriteAsync(request, cancellationToken);
Aspire.Dashboard.Playwright.Tests (15)
Integration\Playwright\Infrastructure\TestTerminalConnectionResolver.cs (1)
26await _connections.Writer.WriteAsync(producer, cancellationToken);
Integration\Playwright\TerminalDockTests.cs (13)
44await updates.Writer.WriteAsync(Change(TerminalChangeType.Added, $"terminal-{i:00}")); 64await updates.Writer.WriteAsync(Change(TerminalChangeType.Activated, "terminal-11")); 70await updates.Writer.WriteAsync(Change(TerminalChangeType.Removed, $"terminal-{i:00}")); 82await updates.Writer.WriteAsync(Change(TerminalChangeType.Removed, id)); 92await updates.Writer.WriteAsync(Change(TerminalChangeType.Added, $"terminal-{i:00}")); 110await updates.Writer.WriteAsync(new WatchTerminalsUpdate 365await updates.Writer.WriteAsync(Change(TerminalChangeType.Removed, closed)); 380await updates.Writer.WriteAsync(Change(TerminalChangeType.Added, "replacement")); 384await updates.Writer.WriteAsync(Change(TerminalChangeType.Removed, "replacement")); 416await updates.Writer.WriteAsync(Change(TerminalChangeType.Removed, "first")); 428await channels.Updates.Writer.WriteAsync(Change(TerminalChangeType.Added, id)); 430await channels.Updates.Writer.WriteAsync(Change(TerminalChangeType.Activated, "first")); 470closeTerminal: (id, token) => Volatile.Read(ref _closes).Writer.WriteAsync(id, token).AsTask());
tests\Shared\TestDashboardClient.cs (1)
258await _sendInteractionUpdateChannel.Writer.WriteAsync(request, cancellationToken);
Aspire.Dashboard.Tests (51)
ChannelExtensionsTests.cs (11)
60channel.Writer.TryWrite(["a", "b", "c"]); 84channel.Writer.TryWrite(["a", "b", "c"]); 110channel.Writer.TryWrite(["a", "b", "c"]); 119resultChannel.Writer.TryWrite(batch); 124resultChannel.Writer.Complete(); 133channel.Writer.TryWrite(["d", "e", "f"]); 141channel.Writer.Complete(); 154channel.Writer.TryWrite(["a", "b", "c"]); 163resultChannel.Writer.TryWrite(batch); 168resultChannel.Writer.Complete(); 177channel.Writer.TryWrite(["d", "e", "f"]);
Integration\DashboardClientAuthTests.cs (1)
180testCalls.ResourceInformationCallsChannel.Writer.TryWrite(new ReceivedCallInfo<ApplicationInformationRequest>(request, context.RequestHeaders));
Model\DashboardClientTests.cs (22)
44channel.Writer.TryWrite(new TerminalServerFrame { Ended = true }); 124channel.Writer.TryWrite(new TerminalServerFrame { Ended = true }); 147channel.Writer.TryComplete(error); 171channel.Writer.TryComplete(new RpcException(new Status(statusCode, "Terminal is unavailable."))); 509await updates.Writer.WriteAsync(new WatchResourcesUpdate { InitialData = initialData }); 564await resources.Writer.WriteAsync(new WatchResourcesUpdate { InitialData = new InitialResourceData() }); 568firstInteractions.Writer.Complete(new RpcException(new Status(StatusCode.Unavailable, "Interaction stream disconnected"))); 573await secondInteractions.Writer.WriteAsync(new WatchInteractionsResponseUpdate { InteractionId = 1 }); 579await resources.Writer.WriteAsync(new WatchResourcesUpdate { InitialData = new InitialResourceData() }); 618subscriptionsStarted.Writer.TryWrite(attempt); 629await first.Writer.WriteAsync(new WatchResourcesUpdate { InitialData = new InitialResourceData() }); 634first.Writer.Complete(failStream ? new RpcException(new Status(StatusCode.Unavailable, "Resource stream disconnected")) : null); 643second.Writer.Complete(failStream ? new RpcException(new Status(StatusCode.Unavailable, "Resource stream disconnected again")) : null); 647await third.Writer.WriteAsync(new WatchResourcesUpdate { InitialData = new InitialResourceData() }); 1110OnTerminalWatchDisposed = () => disposed.Writer.TryWrite(true) 1117await first.Writer.WriteAsync(initial); 1129await first.Writer.WriteAsync(recovery); 1134first.Writer.Complete(failStream ? new RpcException(new Status(StatusCode.Unavailable, "Disconnected")) : null); 1142await second.Writer.WriteAsync(replacement); 1171await channel.Writer.WriteAsync(new WatchTerminalsUpdate { Snapshot = new TerminalDescriptorList() }); 1177channel.Writer.Complete(); 1211channel.Writer.Complete(new RpcException(new Status(StatusCode.Unimplemented, "Older AppHost")));
ResourceOutgoingPeerResolverTests.cs (10)
292await resultChannel.Writer.WriteAsync((++changeCount, Stopwatch.GetTimestamp())); 310await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8080, state: KnownResourceState.Starting))); 320await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Starting))); 329await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Running))); 333resultChannel.Writer.Complete(); 365sourceChannel.Writer.Complete(); 391sourceChannel.Writer.Complete(); 414await sourceChannel.Writer.WriteAsync([new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test", state: KnownResourceState.Starting))]); 415await sourceChannel.Writer.WriteAsync([new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test", state: KnownResourceState.Running))]); 417sourceChannel.Writer.Complete();
TelemetryRepositoryTests\LogTests.cs (1)
978resultChannel.Writer.TryWrite(callCount);
tests\Shared\DashboardTelemetryFixture.cs (5)
49ActivityStopped = activity => ActivityChannel.Writer.TryWrite(activity) 72provider.AddProcessor(new EventLogProcessor(LogChannel.Writer)); 110ActivityChannel.Writer.TryComplete(); 111LogChannel.Writer.TryComplete(); 149LogChannel.Writer.TryWrite(TestDashboardTelemetryLog.Create(record));
tests\Shared\TestDashboardClient.cs (1)
258await _sendInteractionUpdateChannel.Writer.WriteAsync(request, cancellationToken);
Aspire.Hosting (41)
ApplicationModel\ResourceLoggerService.cs (7)
240channel.Writer.TryWrite(new(name, hasSubscribers)); 266channel.Writer.Complete(); 322channel.Writer.TryWrite(logLines); 334channel.Writer.Complete(); 462using var _ = _logStreamCts.Token.Register(() => channel.Writer.TryComplete()); 465void Log(LogEntry log) => channel.Writer.TryWrite(log); 503channel.Writer.TryComplete();
ApplicationModel\ResourceNotificationService.cs (2)
805channel.Writer.TryWrite(resourceEvent); 851channel.Writer.TryComplete();
ApplicationModel\TerminalService.cs (5)
318channel.Writer.TryComplete(); 374channel.Writer.TryComplete(); 435if (channel.Writer.TryWrite(change)) 465channel.Writer.TryWrite(new TerminalSnapshot(snapshot, activatedTerminalId)); 501channel.Writer.TryComplete();
Backchannel\AuxiliaryBackchannelRpcTarget.cs (2)
1691await channel.Writer.WriteAsync(resourceLogLine, logStreamCancellationToken).ConfigureAwait(false); 1707completeWriterTask = Task.WhenAll(tasks).ContinueWith(_ => channel.Writer.Complete(), CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
Backchannel\BackchannelLoggerProvider.cs (3)
41channel.Writer.TryComplete(); 61subscriber.Writer.TryWrite(entry); 77subscriber.Writer.TryComplete();
Dashboard\ResourcePublisher.cs (1)
106await channel.Writer.WriteAsync(new(changeType, snapshot), cancellationToken).ConfigureAwait(false);
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\KubernetesService.cs (2)
346channel.Writer.TryWrite(item); 359channel.Writer.TryComplete(error);
Dcp\ResourceLogSource.cs (4)
91var succeeded = channel.Writer.TryWrite(new ResourceLogEntry(line, lineIsError, timestamp, rawContent)); 95channel.Writer.TryComplete(); 107channel.Writer.TryComplete(ex); 148channel.Writer.TryComplete();
Devcontainers\DevcontainerSettingsWriter.cs (2)
51_portUpdates.Writer.TryWrite(new PortForwardEntry(url, port, protocol, label, openBrowser)); 273_portUpdates.Writer.TryComplete();
InteractionService.cs (2)
694channel.Writer.TryWrite(resourceEvent); 724channel.Writer.TryComplete();
Pipelines\PipelineActivityReporter.cs (9)
76await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 113await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 137await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 170await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 203ActivityItemUpdated.Writer.TryWrite(state); 244await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 275await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 367await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false); 398await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Azure (1)
AzureProvisioningController.cs (1)
1458await _operationChannel.Writer.WriteAsync(queuedOperation, cancellationToken).ConfigureAwait(false);
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 (2)
DevTunnelMonitor.cs (2)
724await _operations.Writer.WriteAsync(new(async () => result = await action().ConfigureAwait(false), completion, cancellationToken), cancellationToken).ConfigureAwait(false); 763_operations.Writer.TryComplete();
Aspire.Hosting.DevTunnels.Tests (6)
TestDevTunnelTimeProvider.cs (1)
16ScheduledDelays.Writer.TryWrite(dueTime);
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 (2)
FoundryExtensions.cs (2)
490progress => progressChannel.Writer.TryWrite(progress), 495progressChannel.Writer.TryComplete();
Aspire.Hosting.Native.Core (1)
Diagnostics\OperationEventSource.cs (1)
94internal ChannelWriter<OperationEvent> Writer => _channel.Writer;
Aspire.Hosting.Native.Core.Tests (3)
SocketConnectionListenerTests.cs (2)
32connected.Writer.TryWrite(true); 90connected.Writer.TryWrite(true);
TestServices\RecordingBackchannelRpc.cs (1)
28_connections.Writer.TryWrite(true);
Aspire.Hosting.Native.Server (2)
Api\PipelineApi.cs (2)
396_activities.Writer.TryComplete(); 417if (!_activities.Writer.TryWrite(activity))
Aspire.Hosting.RemoteHost (3)
src\Shared\ChildProcess.cs (3)
721lines.Writer.TryComplete(); 727lines.Writer.TryComplete(ex); 735await lines.Writer.WriteAsync(new OutputLine(line, standardError), readersCancellation.Token).ConfigureAwait(false);
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 (54)
Cli\CliOrphanDetectorTests.cs (2)
155Assert.True(processRunningChannel.Writer.TryWrite(++processRunningCallCounter)); 226Assert.True(processRunningChannel.Writer.TryWrite(++processRunningCallCounter));
Dashboard\DashboardEventHandlersTests.cs (2)
44testSink.MessageLogged += c => logChannel.Writer.TryWrite(c); 97testSink.MessageLogged += c => logChannel.Writer.TryWrite(c);
Dashboard\DashboardServiceTests.cs (4)
85await getConsoleLogsChannel.Writer.WriteAsync([LogEntry.Create(null, "Test3", isErrorMessage: false)]); 93getConsoleLogsChannel.Writer.TryComplete(); 1736sink.MessageLogged += log => logs.Writer.TryWrite(log); 1816sink.MessageLogged += log => logs.Writer.TryWrite(log);
Dcp\DcpExecutorTests.cs (12)
218endpointEventsProcessed.Writer.TryWrite(true); 496await channel.Writer.WriteAsync(context.DcpResourceName); 1943if (!logStreamPipesChannel.Writer.TryWrite((logStreamType, s))) 2541followStdErrPipeChannel.Writer.TryWrite(pipe); 3014changes.Writer.TryWrite(context); 3082changes.Writer.TryWrite(context); 3915logStreamPipesChannel.Writer.Complete(); 4481allocatedPortChannel.Writer.TryWrite(allocatedEndpoint.Port); 4493connectionStringAvailableChannel.Writer.TryWrite(context.Resource); 4551connectionStringAvailableChannel.Writer.TryWrite(context.Resource); 4635resolvedUrlChannel.Writer.TryWrite(url); 4677resolvedUrlChannel.Writer.TryWrite(url);
Dcp\KubernetesServiceTests.cs (1)
158requestsStarted.Writer.TryWrite(resourceName);
Dcp\TestKubernetesService.cs (7)
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))); 485_ = c.Writer.TryComplete();
DistributedApplicationTests.cs (1)
1216await beforeResourceStartedEvents.Writer.WriteAsync(e, ct);
Health\ResourceHealthCheckServiceTests.cs (2)
153channel.Writer.TryWrite(@event); 300await channel.Writer.WriteAsync(timeProvider.GetUtcNow());
InteractionServiceTests.cs (3)
131await updates.Writer.WriteAsync(interaction); 904await updates.Writer.WriteAsync(interaction); 957await updates.Writer.WriteAsync(interaction);
ResourceCommandServiceTests.cs (4)
147await commandResourcesChannel.Writer.WriteAsync(e.ResourceName); 156commandResourcesChannel.Writer.Complete(); 185await commandResourcesChannel.Writer.WriteAsync(e.ResourceName); 194commandResourcesChannel.Writer.Complete();
ResourceLoggerServiceTests.cs (6)
264consoleLogsChannel0.Writer.TryWrite([LogEntry.Create(timestamp: null, logMessage: "instance0!", isErrorMessage: false)]); 265consoleLogsChannel0.Writer.Complete(); 268consoleLogsChannel1.Writer.TryWrite([LogEntry.Create(timestamp: null, logMessage: "instance1!", isErrorMessage: false)]); 269consoleLogsChannel1.Writer.Complete(); 483consoleLogsChannel.Writer.TryWrite([CreateLogEntry("dcp-snapshot-log")]); 484consoleLogsChannel.Writer.Complete();
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);
VersionChecking\VersionCheckServiceTests.cs (5)
97interactionService.Interactions.Writer.Complete(); 181interactionService.Interactions.Writer.Complete(); 212interactionService.Interactions.Writer.Complete(); 241interactionService.Interactions.Writer.Complete(); 282interactionService.Interactions.Writer.Complete();
Aspire.Hosting.TestUtilities (4)
Utils\Grpc\TestAsyncStreamReader.cs (2)
24if (!_channel.Writer.TryWrite(message)) 32_channel.Writer.Complete(ex);
Utils\Grpc\TestServerStreamWriter.cs (2)
27_channel.Writer.Complete(ex); 58if (!_channel.Writer.TryWrite(message))
Aspire.TerminalHost (2)
DcpUpstreamAdapter.cs (2)
405await _outputChannel.Writer.WriteAsync(payload, ct).ConfigureAwait(false); 467_outputChannel.Writer.TryComplete(error);
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 (2)
parent\dotnet\Commands\Test\MTP\TestApplicationActionQueue.cs (2)
86if (!_channel.Writer.TryWrite(testApplication)) 95_channel.Writer.Complete();
dotnet-watch (1)
UI\SpectreBuildParametersSelectionPrompt.cs (1)
125=> _channel.Writer.TryWrite(key);
GenerateDocumentationAndConfigFiles (7)
src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
48tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
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.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)
1974closeMessage = await ProcessMessagesAsync(message, connectionState, invocationMessageChannel.Writer).ConfigureAwait(false); 2026invocationMessageChannel.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)
110_channel.Writer.TryComplete(new InvalidOperationException("Server provided a result in a completion response to a streamed invocation.")); 125_channel.Writer.TryComplete(); 139_channel.Writer.TryComplete(exception); 146while (!_channel.Writer.TryWrite(item)) 148if (!await _channel.Writer.WaitToWriteAsync().ConfigureAwait(false)) 170_channel.Writer.TryComplete(new OperationCanceledException());
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
228_waitForAck.Writer.TryWrite(newCount);
Microsoft.AspNetCore.SignalR.Core (5)
Internal\ChannelBasedSemaphore.cs (2)
20_channel.Writer.TryWrite(1); 37if (!_channel.Writer.TryWrite(1))
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
228_waitForAck.Writer.TryWrite(newCount);
StreamTracker.cs (2)
159return _channel.Writer.WriteAsync((T?)o).AsTask(); 164_channel.Writer.TryComplete(ex);
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 (7)
src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
48tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.AnalyzerUtilities (7)
src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
48tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.CodeStyle (7)
src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
48tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.ResxSourceGenerator (7)
src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
48tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.Workspaces (7)
src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
48tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.DotNet.HotReload.Utils.Generator (2)
Util\FSWGen.cs (2)
30_channel?.Writer.WriteAsync (eventArgs).AsTask().Wait(); 46_channel?.Writer.Complete();
Microsoft.DotNet.HotReload.Watch (1)
Aspire\AspireServiceFactory.cs (1)
135var writeResult = outputChannel.Writer.TryWrite(line);
Microsoft.Extensions.AI (2)
ChatCompletion\AnonymousDelegatingChatClient.cs (2)
146await updates.Writer.WriteAsync(update, cancellationToken); 157_ = updates.Writer.TryComplete(error);
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 (2)
AsyncSweeper.cs (2)
224_paramChannel.Writer.Complete(); 229_paramChannel.Writer.TryWrite(new ParameterSetWithId(_numGenerated++, paramSet));
Roslyn.Diagnostics.Analyzers (7)
src\roslyn\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\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (2)
48tasks[i] = ProcessAsync(streams[i], channel.Writer, cancellationToken); 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Stress.ApiService (4)
ProducerConsumer.cs (2)
63await _channel.Writer.WriteAsync(data); 65_channel.Writer.Complete();
Program.cs (2)
360channel.Writer.TryWrite($"Logged {logCount} messages."); 366channel.Writer.Complete();
System.Diagnostics.Process (3)
System\Diagnostics\Process.Multiplexing.cs (3)
577await channel.Writer.WriteAsync(new ProcessOutputLine(line, standardError), ct).ConfigureAwait(false); 582channel.Writer.TryComplete(ex); 588channel.Writer.TryComplete();
System.IO.FileSystem.Watcher (3)
System\IO\FileSystemWatcher.Linux.cs (3)
1095_eventQueue.Writer.Complete(); 1227_eventQueue.Writer.TryWrite(ev); 1236_eventQueue.Writer.TryWrite(WatcherEvent.Error(exception));
System.Net.Http (2)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)
1210if (!_writeChannel.Writer.TryWrite(writeEntry)) 1941bool completed = _writeChannel.Writer.TryComplete();
System.Net.Quic (9)
System\Net\Quic\QuicConnection.cs (5)
664_acceptQueue.Writer.TryComplete(exception); 675_acceptQueue.Writer.TryComplete(exception); 689_acceptQueue.Writer.TryComplete(exception); 715if (!_acceptQueue.Writer.TryWrite(stream)) 866_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}";