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) =>
75 references to WriteAsync
aspire (3)
Interaction\ExtensionInteractionService.cs (3)
68await _extensionTaskChannel.Writer.WriteAsync(async () => 100await _extensionTaskChannel.Writer.WriteAsync(async () => 134await _extensionTaskChannel.Writer.WriteAsync(async () =>
Aspire.Dashboard (1)
ServiceClient\DashboardClient.cs (1)
531await _incomingInteractionChannel.Writer.WriteAsync(request, cancellationToken).ConfigureAwait(false);
Aspire.Dashboard.Components.Tests (6)
Interactions\InteractionsProviderTests.cs (5)
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);
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\PublishingActivityProgressReporter.cs (7)
399await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 438await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 462await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 494await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 533await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 558await ActivityItemUpdated.Writer.WriteAsync(state, cancellationToken).ConfigureAwait(false); 652await ActivityItemUpdated.Writer.WriteAsync(activity, cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Tests (4)
Dcp\DcpExecutorTests.cs (1)
76await channel.Writer.WriteAsync(context.DcpResourceName);
DistributedApplicationTests.cs (1)
622await beforeResourceStartedEvents.Writer.WriteAsync(e, ct);
Health\ResourceHealthCheckServiceTests.cs (1)
301await channel.Writer.WriteAsync(timeProvider.GetUtcNow());
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);