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

54 references to WriteAsync

aspire (5)

Interaction\ExtensionInteractionService.cs (5)

107await _extensionTaskChannel.Writer.WriteAsync(async () => 159await _extensionTaskChannel.Writer.WriteAsync(async () => 207await _extensionTaskChannel.Writer.WriteAsync(async () => 239await _extensionTaskChannel.Writer.WriteAsync(async () => 271await _extensionTaskChannel.Writer.WriteAsync(async () =>

Aspire.Dashboard (1)

ServiceClient\DashboardClient.cs (1)

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

Aspire.Dashboard.Components.Tests (11)

Interactions\InteractionsProviderTests.cs (10)

tests\Shared\TestDashboardClient.cs (1)

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

Aspire.Dashboard.Tests (5)

ResourceOutgoingPeerResolverTests.cs (4)

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

tests\Shared\TestDashboardClient.cs (1)

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

Aspire.Hosting (10)

Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)

714await channel.Writer.WriteAsync(new ResourceLogLine

Dashboard\ResourcePublisher.cs (1)

106await channel.Writer.WriteAsync(new(changeType, snapshot), cancellationToken).ConfigureAwait(false);

Pipelines\PipelineActivityReporter.cs (8)

Aspire.Hosting.Tests (9)

Dashboard\DashboardServiceTests.cs (1)

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

Dcp\DcpExecutorTests.cs (1)

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

DistributedApplicationTests.cs (1)

1068await beforeResourceStartedEvents.Writer.WriteAsync(e, ct);

Health\ResourceHealthCheckServiceTests.cs (1)

300await channel.Writer.WriteAsync(timeProvider.GetUtcNow());

InteractionServiceTests.cs (3)

130await updates.Writer.WriteAsync(interaction); 821await updates.Writer.WriteAsync(interaction); 874await updates.Writer.WriteAsync(interaction);

ResourceCommandServiceTests.cs (2)

90await commandResourcesChannel.Writer.WriteAsync(e.ResourceName); 128await commandResourcesChannel.Writer.WriteAsync(e.ResourceName);

GenerateDocumentationAndConfigFiles (1)

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

68await writer.WriteAsync(value, cancellationToken).ConfigureAwait(false);

Microsoft.AspNetCore.SignalR.Core (1)

StreamTracker.cs (1)

134return _channel.Writer.WriteAsync((T?)o).AsTask();

Microsoft.CodeAnalysis.Analyzers (1)

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

68await writer.WriteAsync(value, cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.AnalyzerUtilities (1)

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

68await writer.WriteAsync(value, cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.CodeStyle (1)

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

68await writer.WriteAsync(value, cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.ResxSourceGenerator (1)

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

68await writer.WriteAsync(value, cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.Workspaces (1)

src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

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

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

602/// <summary>Represents a blocked writer from <see cref="ChannelWriter{T}.WriteAsync"/>.</summary>