5 overrides of WriteAsync
System.Threading.Channels (5)
System\Threading\Channels\BoundedChannel.cs (1)
515public override ValueTask WriteAsync(T item, CancellationToken cancellationToken)
System\Threading\Channels\RendezvousChannel.cs (1)
372public override ValueTask WriteAsync(T item, CancellationToken cancellationToken)
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
347public override ValueTask WriteAsync(T item, CancellationToken cancellationToken) =>
System\Threading\Channels\UnboundedChannel.cs (1)
297public override ValueTask WriteAsync(T item, CancellationToken cancellationToken) =>
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
293public override ValueTask WriteAsync(T item, CancellationToken cancellationToken) =>
174 references to WriteAsync
aspire (8)
Commands\PsCommand.cs (1)
247await updates.Writer.WriteAsync(new ConnectionsUpdate(connections), followCancellationToken).ConfigureAwait(false);
Interaction\ExtensionInteractionService.cs (6)
78await _extensionTaskChannel.Writer.WriteAsync(() => 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 () =>
Projects\ProjectLocator.cs (1)
311await candidateWriter.WriteAsync(appHostProject, cancellationToken).ConfigureAwait(false);
Aspire.Cli.Tests (2)
Backchannel\ResourceSnapshotWatcherTests.cs (2)
569await source.Writer.WriteAsync(firstSnapshot); 582await source.Writer.WriteAsync(new ResourceSnapshot
Aspire.Dashboard (1)
ServiceClient\DashboardClient.cs (1)
845await _incomingInteractionChannel.Writer.WriteAsync(request, cancellationToken).ConfigureAwait(false);
Aspire.Dashboard.Components.Tests (95)
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 (10)
39await updates.Writer.WriteAsync(new WatchInteractionsResponseUpdate 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 (3)
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 (36)
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 435await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "first")); 438await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Removed, "first")); 448await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Added, "second")); 465await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second", "third")); 473await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Removed, "second")); 498await updates.Writer.WriteAsync(snapshot); 507await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Removed, "terminal-id")); 536await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second")); 564await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Retitled, "first", "Updated while hidden")); 570await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "second")); 605await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("terminal")); 631await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("terminal")); 658await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", terminalId)); 671await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", terminalId, "third")); 704await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "detached")); 719await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("remaining")); 745await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("first", "second")); 756await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Removed, "first")); 787await updates.Writer.WriteAsync(TerminalSetupHelpers.Change(TerminalChangeType.Activated, "terminal"));
Layout\TerminalDockWindowTrackingTests.cs (5)
42await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("terminal")); 94await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("active", "inactive")); 127await updates.Writer.WriteAsync(TerminalSetupHelpers.Snapshot("active", "inactive")); 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\ResourcesTests.cs (1)
639await channel.Writer.WriteAsync([new ResourceViewModelChange(
Pages\TerminalsTests.cs (4)
485await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, 492await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Delete, last)]); 506await updates.Writer.WriteAsync([new(ResourceViewModelChangeType.Upsert, ModelTestHelpers.CreateResource("first"))]); 580await 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\TestDashboardClient.cs (1)
258await _sendInteractionUpdateChannel.Writer.WriteAsync(request, cancellationToken);
Aspire.Dashboard.Tests (31)
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());
Model\DashboardClientTests.cs (10)
509await updates.Writer.WriteAsync(new WatchResourcesUpdate { InitialData = initialData }); 564await resources.Writer.WriteAsync(new WatchResourcesUpdate { InitialData = new InitialResourceData() }); 573await secondInteractions.Writer.WriteAsync(new WatchInteractionsResponseUpdate { InteractionId = 1 }); 579await resources.Writer.WriteAsync(new WatchResourcesUpdate { InitialData = new InitialResourceData() }); 629await first.Writer.WriteAsync(new WatchResourcesUpdate { InitialData = new InitialResourceData() }); 647await third.Writer.WriteAsync(new WatchResourcesUpdate { InitialData = new InitialResourceData() }); 1117await first.Writer.WriteAsync(initial); 1129await first.Writer.WriteAsync(recovery); 1142await second.Writer.WriteAsync(replacement); 1171await channel.Writer.WriteAsync(new WatchTerminalsUpdate { Snapshot = new TerminalDescriptorList() });
ResourceOutgoingPeerResolverTests.cs (6)
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))); 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))]);
tests\Shared\TestDashboardClient.cs (1)
258await _sendInteractionUpdateChannel.Writer.WriteAsync(request, cancellationToken);
Aspire.Hosting (10)
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
1691await channel.Writer.WriteAsync(resourceLogLine, logStreamCancellationToken).ConfigureAwait(false);
Dashboard\ResourcePublisher.cs (1)
106await channel.Writer.WriteAsync(new(changeType, snapshot), cancellationToken).ConfigureAwait(false);
Pipelines\PipelineActivityReporter.cs (8)
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); 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)
1410await _operationChannel.Writer.WriteAsync(queuedOperation, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.DevTunnels (1)
DevTunnelMonitor.cs (1)
724await _operations.Writer.WriteAsync(new(async () => result = await action().ConfigureAwait(false), completion, cancellationToken), cancellationToken).ConfigureAwait(false);
Aspire.Hosting.RemoteHost (1)
src\Shared\ChildProcess.cs (1)
735await lines.Writer.WriteAsync(new OutputLine(line, standardError), readersCancellation.Token).ConfigureAwait(false);
Aspire.Hosting.Tests (9)
Dashboard\DashboardServiceTests.cs (1)
85await getConsoleLogsChannel.Writer.WriteAsync([LogEntry.Create(null, "Test3", isErrorMessage: false)]);
Dcp\DcpExecutorTests.cs (1)
496await channel.Writer.WriteAsync(context.DcpResourceName);
DistributedApplicationTests.cs (1)
1216await beforeResourceStartedEvents.Writer.WriteAsync(e, ct);
Health\ResourceHealthCheckServiceTests.cs (1)
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 (2)
147await commandResourcesChannel.Writer.WriteAsync(e.ResourceName); 185await commandResourcesChannel.Writer.WriteAsync(e.ResourceName);
Aspire.TerminalHost (1)
DcpUpstreamAdapter.cs (1)
400await _outputChannel.Writer.WriteAsync(payload, ct).ConfigureAwait(false);
GenerateDocumentationAndConfigFiles (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
62await writer.WriteAsync(value, cancellationToken).ConfigureAwait(false);
Microsoft.AspNetCore.SignalR.Client.Core (1)
HubConnection.cs (1)
1631await invocationMessageWriter.WriteAsync(invocation).ConfigureAwait(false);
Microsoft.AspNetCore.SignalR.Core (1)
StreamTracker.cs (1)
159return _channel.Writer.WriteAsync((T?)o).AsTask();
Microsoft.CodeAnalysis.Analyzers (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
62await writer.WriteAsync(value, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.AnalyzerUtilities (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
62await writer.WriteAsync(value, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.CodeStyle (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
62await writer.WriteAsync(value, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.ResxSourceGenerator (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
62await writer.WriteAsync(value, cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis.Workspaces (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
62await writer.WriteAsync(value, cancellationToken).ConfigureAwait(false);
Microsoft.DotNet.HotReload.Utils.Generator (1)
Util\FSWGen.cs (1)
30_channel?.Writer.WriteAsync (eventArgs).AsTask().Wait();
Microsoft.Extensions.AI (1)
ChatCompletion\AnonymousDelegatingChatClient.cs (1)
146await updates.Writer.WriteAsync(update, cancellationToken);
Roslyn.Diagnostics.Analyzers (1)
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
62await writer.WriteAsync(value, cancellationToken).ConfigureAwait(false);
Stress.ApiService (1)
ProducerConsumer.cs (1)
63await _channel.Writer.WriteAsync(data);
System.Diagnostics.Process (1)
System\Diagnostics\Process.Multiplexing.cs (1)
577await channel.Writer.WriteAsync(new ProcessOutputLine(line, standardError), ct).ConfigureAwait(false);
System.Threading.Channels (1)
System\Threading\Channels\AsyncOperation.cs (1)
603/// <summary>Represents a blocked writer from <see cref="ChannelWriter{T}.WriteAsync"/>.</summary>