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)

348public override ValueTask WriteAsync(T item, CancellationToken cancellationToken) =>

System\Threading\Channels\UnboundedChannel.cs (1)

287public override ValueTask WriteAsync(T item, CancellationToken cancellationToken) =>

System\Threading\Channels\UnboundedPriorityChannel.cs (1)

293public override ValueTask WriteAsync(T item, CancellationToken cancellationToken) =>

78 references to WriteAsync

aspire (3)

Interaction\ExtensionInteractionService.cs (3)

70await _extensionTaskChannel.Writer.WriteAsync(async () => 97await _extensionTaskChannel.Writer.WriteAsync(async () => 126await _extensionTaskChannel.Writer.WriteAsync(async () =>

Aspire.Dashboard (1)

ServiceClient\DashboardClient.cs (1)

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

Aspire.Dashboard.Components.Tests (7)

Interactions\InteractionsProviderTests.cs (6)

90await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 134await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 153await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 190await interactionsChannel.Writer.WriteAsync(new WatchInteractionsResponseUpdate 253await interactionsChannel.Writer.WriteAsync(response); 318await interactionsChannel.Writer.WriteAsync(response);

Shared\TestDashboardClient.cs (1)

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

Aspire.Dashboard.Tests (4)

ResourceOutgoingPeerResolverTests.cs (4)

132await resultChannel.Writer.WriteAsync(++changeCount); 150await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8080, state: KnownResourceState.Starting))); 158await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Starting))); 166await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Running)));

Aspire.Hosting (8)

Dashboard\ResourcePublisher.cs (1)

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

Publishing\PublishingActivityReporter.cs (7)

54await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 90await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 120await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 152await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 191await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 216await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 311await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false);

Aspire.Hosting.Tests (6)

Dashboard\DashboardServiceTests.cs (1)

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

Dcp\DcpExecutorTests.cs (1)

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

DistributedApplicationTests.cs (1)

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

Health\ResourceHealthCheckServiceTests.cs (1)

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

InteractionServiceTests.cs (1)

127await updates.Writer.WriteAsync(interaction);

ResourceCommandServiceTests.cs (1)

67await commandResourcesChannel.Writer.WriteAsync(e.ResourceName);

ClientSample (3)

UploadSample.cs (3)

49await channel.Writer.WriteAsync(c.ToString()); 73await source.WriteAsync(c); 91await channel.Writer.WriteAsync(phrase);

GenerateDocumentationAndConfigFiles (1)

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

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

InMemory.FunctionalTests (1)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

1080ToClientAcceptQueue.Writer.WriteAsync(stream);

Metrics (1)

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

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

Metrics.Legacy (1)

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

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

Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

1080ToClientAcceptQueue.Writer.WriteAsync(stream);

Microsoft.AspNetCore.SignalR.Client.Core (1)

HubConnection.cs (1)

1316await invocationMessageWriter.WriteAsync(invocation).ConfigureAwait(false);

Microsoft.AspNetCore.SignalR.Client.FunctionalTests (5)

HubConnectionTests.cs (2)

802await channelWriter.Writer.WriteAsync("1").AsTask().DefaultTimeout(); 804await channelWriter.Writer.WriteAsync("2").AsTask().DefaultTimeout();

Hubs.cs (3)

233await channel.Writer.WriteAsync(i); 261await output.Writer.WriteAsync(item); 285await output.Writer.WriteAsync(item);

Microsoft.AspNetCore.SignalR.Client.Tests (6)

HubConnectionTests.cs (6)

448await channel.Writer.WriteAsync(number).AsTask().DefaultTimeout(); 489await channel.Writer.WriteAsync(item); 520await channel.Writer.WriteAsync(item); 565await channel.Writer.WriteAsync(number); 685await channel.Writer.WriteAsync(5); 686await channel.Writer.WriteAsync(10);

Microsoft.AspNetCore.SignalR.Core (1)

StreamTracker.cs (1)

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

Microsoft.AspNetCore.SignalR.Microbenchmarks (1)

DefaultHubDispatcherBenchmark.cs (1)

166await channel.Writer.WriteAsync(i);

Microsoft.AspNetCore.SignalR.Tests (11)

HubConnectionHandlerTestUtils\Hubs.cs (3)

710await channel.Writer.WriteAsync(i.ToString(CultureInfo.InvariantCulture)); 822await output.Writer.WriteAsync("echo:" + item); 1138await channel.Writer.WriteAsync(i);

NativeAotTests.cs (8)

81await channel.Writer.WriteAsync("some data"); 82await channel.Writer.WriteAsync("some more data"); 83await channel.Writer.WriteAsync("even more data"); 113await channelShorts.Writer.WriteAsync(9); 114await channelShorts.Writer.WriteAsync(8); 115await channelShorts.Writer.WriteAsync(7); 255await output.Writer.WriteAsync("echo:" + item); 289await output.Writer.WriteAsync(item);

Microsoft.CodeAnalysis.Analyzers (1)

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

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

Microsoft.CodeAnalysis.AnalyzerUtilities (1)

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

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

Microsoft.CodeAnalysis.BannedApiAnalyzers (1)

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

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

Microsoft.CodeAnalysis.CodeStyle (1)

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

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

Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (1)

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

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

Microsoft.CodeAnalysis.PublicApiAnalyzers (1)

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

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

Microsoft.CodeAnalysis.ResxSourceGenerator (1)

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

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

Microsoft.CodeAnalysis.Workspaces (1)

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

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

Microsoft.Extensions.AI (1)

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

148await updates.Writer.WriteAsync(update, cancellationToken);

Roslyn.Diagnostics.Analyzers (1)

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

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

SignalRSamples (2)

Hubs\Streaming.cs (1)

38await channel.Writer.WriteAsync(i);

Hubs\UploadHub.cs (1)

74await output.Writer.WriteAsync("echo:" + item);

Stress.ApiService (1)

ProducerConsumer.cs (1)

63await _channel.Writer.WriteAsync(data);

System.Threading.Channels (1)

System\Threading\Channels\AsyncOperation.cs (1)

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

Test.Utilities (1)

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

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

Text.Analyzers (1)

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

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