WriteAsync

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) =>

67 references to WriteAsync

aspire (8)

Commands\PsCommand.cs (1)

200await updates.Writer.WriteAsync(new ConnectionsUpdate(connections), followCancellationToken).ConfigureAwait(false);

Interaction\ExtensionInteractionService.cs (6)

72await _extensionTaskChannel.Writer.WriteAsync(() => 154await _extensionTaskChannel.Writer.WriteAsync(async () => 215await _extensionTaskChannel.Writer.WriteAsync(async () => 277await _extensionTaskChannel.Writer.WriteAsync(async () => 315await _extensionTaskChannel.Writer.WriteAsync(async () => 354await _extensionTaskChannel.Writer.WriteAsync(async () =>

Projects\ProjectLocator.cs (1)

311await candidateWriter.WriteAsync(appHostProject, cancellationToken).ConfigureAwait(false);

Aspire.Cli.Tests (2)

Backchannel\ResourceSnapshotWatcherTests.cs (2)

480await source.Writer.WriteAsync(firstSnapshot); 493await source.Writer.WriteAsync(new ResourceSnapshot

Aspire.Dashboard (1)

ServiceClient\DashboardClient.cs (1)

797await _incomingInteractionChannel.Writer.WriteAsync(request, cancellationToken).ConfigureAwait(false);

Aspire.Dashboard.Components.Tests (14)

Interactions\InteractionsProviderTests.cs (13)

tests\Shared\TestDashboardClient.cs (1)

171await _sendInteractionUpdateChannel.Writer.WriteAsync(request, cancellationToken);

Aspire.Dashboard.Tests (7)

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)

171await _sendInteractionUpdateChannel.Writer.WriteAsync(request, cancellationToken);

Aspire.Hosting (10)

Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)

1669await 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)

Aspire.Hosting.Azure (1)

AzureProvisioningController.cs (1)

1413await _operationChannel.Writer.WriteAsync(queuedOperation, cancellationToken).ConfigureAwait(false);

Aspire.Hosting.Tests (9)

Dashboard\DashboardServiceTests.cs (1)

80await getConsoleLogsChannel.Writer.WriteAsync([LogEntry.Create(null, "Test3", isErrorMessage: false)]);

Dcp\DcpExecutorTests.cs (1)

144await channel.Writer.WriteAsync(context.DcpResourceName);

DistributedApplicationTests.cs (1)

1212await 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)

146await commandResourcesChannel.Writer.WriteAsync(e.ResourceName); 184await 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)

1624await 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>