WriteAsync

6 overrides of WriteAsync

Microsoft.AspNetCore.Server.Kestrel.Core (3)

Internal\Http\HttpResponsePipeWriter.cs (1)

64public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)

Internal\Infrastructure\StatusCheckPipeWriter.cs (1)

88public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)

Internal\Infrastructure\WrappingPipeWriter.cs (1)

66public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)

src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)

47public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)

System.IO.Pipelines (2)

System\IO\Pipelines\Pipe.DefaultPipeWriter.cs (1)

48public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)

System\IO\Pipelines\StreamPipeWriter.cs (1)

279public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)

37 references to WriteAsync

Aspire.Hosting.Tests (2)

Dcp\DcpExecutorTests.cs (2)

651await pipes.StandardOut.Writer.WriteAsync(Encoding.UTF8.GetBytes("2024-08-19T06:10:33.473275911Z Hello world" + Environment.NewLine)); 662await pipes.StandardErr.Writer.WriteAsync(Encoding.UTF8.GetBytes("2024-08-19T06:10:32.661Z Next" + Environment.NewLine));

Microsoft.AspNetCore.Components.Server (1)

Circuits\RemoteJSDataStream.cs (1)

125await _pipe.Writer.WriteAsync(chunk, _streamCancellationToken);

Microsoft.AspNetCore.Http.Connections (1)

src\aspnetcore\src\SignalR\common\Shared\PipeWriterStream.cs (1)

76var task = _pipeWriter.WriteAsync(source, cancellationToken);

Microsoft.AspNetCore.Http.Connections.Client (2)

Internal\ServerSentEventsTransport.cs (1)

146var flushResult = await _application.Output.WriteAsync(item.Data, default).ConfigureAwait(false);

src\aspnetcore\src\SignalR\common\Shared\PipeWriterStream.cs (1)

76var task = _pipeWriter.WriteAsync(source, cancellationToken);

Microsoft.AspNetCore.OutputCaching (2)

RecyclableReadOnlySequenceSegment.cs (2)

108await destination.WriteAsync(source.First, cancellationToken); 116await destination.WriteAsync(segment, cancellationToken);

Microsoft.AspNetCore.Server.IIS (2)

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

98return _output.WriteAsync(buffer.AsMemory(offset, count), cancellationToken).GetAsTask(); 103return _output.WriteAsync(source, cancellationToken).GetAsValueTask();

Microsoft.AspNetCore.Server.Kestrel.Core (6)

Internal\Http2\Http2Connection.cs (1)

597await _context.Transport.Output.WriteAsync(responseBytes);

Internal\Infrastructure\StatusCheckPipeWriter.cs (1)

91return _inner.WriteAsync(source, cancellationToken);

Internal\Infrastructure\WrappingPipeWriter.cs (1)

68return _inner.WriteAsync(source, cancellationToken);

Internal\WebTransport\WebTransportSession.cs (1)

140await stream.Transport.Output.WriteAsync(OutputStreamHeader, cancellationToken);

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

98return _output.WriteAsync(buffer.AsMemory(offset, count), cancellationToken).GetAsTask(); 103return _output.WriteAsync(source, cancellationToken).GetAsValueTask();

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)

src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)

49return _inner.WriteAsync(source, cancellationToken);

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

src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (3)

175writeTask = _writer.WriteAsync(messageBytes, cancellationToken); 180writeTask = _writer.WriteAsync(messageBytes, cancellationToken); 287finalResult = await _writer.WriteAsync(item.HubMessage).ConfigureAwait(false);

src\aspnetcore\src\SignalR\common\Shared\PipeWriterStream.cs (1)

76var task = _pipeWriter.WriteAsync(source, cancellationToken);

Microsoft.AspNetCore.SignalR.Core (5)

HubConnectionContext.cs (2)

411return _connectionContext.Transport.Output.WriteAsync(buffer, cancellationToken); 528await _connectionContext.Transport.Output.WriteAsync(_cachedPingMessage);

src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (3)

Microsoft.AspNetCore.SignalR.Specification.Tests (2)

src\aspnetcore\src\SignalR\common\testassets\Tests.Utils\TestClient.cs (2)

75await Connection.Application.Output.WriteAsync(GetHandshakeRequestMessage()); 236await Connection.Application.Output.WriteAsync(payload);

Microsoft.AspNetCore.TestHost (2)

ResponseBodyWriterStream.cs (2)

70await _responseWriter.WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken); 75await _responseWriter.WriteAsync(buffer, cancellationToken);

Microsoft.AspNetCore.WebUtilities (1)

PagedByteBuffer.cs (1)

92await writer.WriteAsync(page.AsMemory(0, length), cancellationToken);

System.IO.Pipelines (6)

System\IO\Pipelines\PipeReader.cs (1)

191(destination, memory, cancellationToken) => destination.WriteAsync(memory, cancellationToken),

System\IO\Pipelines\PipeWriter.cs (2)

35/// <summary>Cancels the pending <see cref="System.IO.Pipelines.PipeWriter.FlushAsync(System.Threading.CancellationToken)" /> or <see cref="System.IO.Pipelines.PipeWriter.WriteAsync(System.ReadOnlyMemory{byte},System.Threading.CancellationToken)" /> operation without causing the operation to throw and without completing the <see cref="System.IO.Pipelines.PipeWriter" />. If there is no pending operation, this cancels the next operation.</summary> 36/// <remarks>The canceled <see cref="System.IO.Pipelines.PipeWriter.FlushAsync(System.Threading.CancellationToken)" /> or <see cref="System.IO.Pipelines.PipeWriter.WriteAsync(System.ReadOnlyMemory{byte},System.Threading.CancellationToken)" /> operation returns a <see cref="System.IO.Pipelines.FlushResult" /> where <see cref="System.IO.Pipelines.FlushResult.IsCanceled" /> is <see langword="true" />.</remarks>

System\IO\Pipelines\PipeWriterStream.cs (2)

79ValueTask<FlushResult> valueTask = _pipeWriter.WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken); 87ValueTask<FlushResult> valueTask = _pipeWriter.WriteAsync(buffer, cancellationToken);

System\IO\Pipelines\StreamPipeReader.cs (1)

337FlushResult flushResult = await destination.WriteAsync(segment.Memory.Slice(segmentIndex), tokenSource.Token).ConfigureAwait(false);