4 overrides of WriteAsync
System.Threading.Channels (4)
System\Threading\Channels\BoundedChannel.cs (1)
524public override ValueTask WriteAsync(T item, CancellationToken cancellationToken)
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
350public override ValueTask WriteAsync(T item, CancellationToken cancellationToken) =>
System\Threading\Channels\UnboundedChannel.cs (1)
311public override ValueTask WriteAsync(T item, CancellationToken cancellationToken) =>
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
316public override ValueTask WriteAsync(T item, CancellationToken cancellationToken) =>
43 references to WriteAsync
Aspire.Dashboard.Tests (4)
ResourceOutgoingPeerResolverTests.cs (4)
131await resultChannel.Writer.WriteAsync(++changeCount); 149await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8080, state: KnownResourceState.Starting))); 157await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Starting))); 165await sourceChannel.Writer.WriteAsync(new ResourceViewModelChange(ResourceViewModelChangeType.Upsert, CreateResource("test2", serviceAddress: "localhost", servicePort: 8081, state: KnownResourceState.Running)));
Aspire.Hosting.Tests (3)
Dcp\DcpExecutorTests.cs (1)
76await channel.Writer.WriteAsync(context.DcpResourceName);
DistributedApplicationTests.cs (1)
526await beforeResourceStartedEvents.Writer.WriteAsync(e, ct);
Health\ResourceHealthCheckServiceTests.cs (1)
301await channel.Writer.WriteAsync(timeProvider.GetUtcNow());
ClientSample (3)
UploadSample.cs (3)
49await channel.Writer.WriteAsync(c.ToString()); 73await source.WriteAsync(c); 91await channel.Writer.WriteAsync(phrase);
InMemory.FunctionalTests (1)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
1081ToClientAcceptQueue.Writer.WriteAsync(stream);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
1081ToClientAcceptQueue.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.CodeStyle (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);
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);