WriteAsync

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

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

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)

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

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

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

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

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)

RawSample.cs (1)

106await output.WriteAsync(Encoding.UTF8.GetBytes(result));

Authorization\SampleAuthorizationMiddlewareResultHandler.cs (1)

58httpContext.Response.OnStarting(() => httpContext.Response.BodyWriter.WriteAsync(Encoding.UTF8.GetBytes(message)).AsTask());

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

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

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

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

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

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

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

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

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

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

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

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

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

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

ChunkedRequestTests.cs (4)

54await response.BodyWriter.WriteAsync(readResult.Buffer.ToArray()); 929await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 981await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 1092await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11));

ChunkedResponseTests.cs (16)

ConnectionMiddlewareTests.cs (2)

299await context.Response.BodyWriter.WriteAsync(Encoding.ASCII.GetBytes("Hello ")); 301await context.Response.BodyWriter.WriteAsync(Encoding.ASCII.GetBytes("World!"));

Http2\Http2ConnectionTests.cs (1)

1374await context.Response.BodyWriter.WriteAsync(readResult.Buffer.ToArray());

Http2\Http2StreamTests.cs (5)

4295var result = await httpContext.Response.BodyWriter.WriteAsync(payload); 4328var cancelledResult = await httpContext.Response.BodyWriter.WriteAsync(payload); 4332var goodResult = await httpContext.Response.BodyWriter.WriteAsync(secondPayload); 4381await response.BodyWriter.WriteAsync(Encoding.ASCII.GetBytes("hello, world")); 4581await response.BodyWriter.WriteAsync(Encoding.ASCII.GetBytes("hello, world\r\n"));

Http2\Http2WebSocketTests.cs (3)

458ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.BodyWriter.WriteAsync(new byte[1] { 0x00 }).AsTask()); 467ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.BodyWriter.WriteAsync(new byte[1] { 0x00 }).AsTask()); 527await context.Response.BodyWriter.WriteAsync(new byte[1] { 0x02 });

Http3\Http3StreamTests.cs (4)

734await context.Response.BodyWriter.WriteAsync(new byte[] { data[i] }); 773var result = await context.Response.BodyWriter.WriteAsync(payload); 804var cancelledResult = await context.Response.BodyWriter.WriteAsync(payload); 808var goodResult = await context.Response.BodyWriter.WriteAsync(secondPayload);

Http3\WebTransport\WebTransportStreamTests.cs (1)

42await stream.Transport.Output.WriteAsync(input, CancellationToken.None);

RequestTests.cs (3)

1917await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 1963await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 2046await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11));

ResponseTests.cs (25)

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

49return _inner.WriteAsync(source, cancellationToken);

UpgradeTests.cs (1)

34await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.BodyWriter.WriteAsync(new byte[1]).AsTask());

Http3\Http3RequestTests.cs (1)

1224await context.Response.BodyWriter.WriteAsync(TestData);

HttpClientHttp2InteropTests.cs (2)

282await context.Response.BodyWriter.WriteAsync(sequence.First).DefaultTimeout(); 339await context.Response.BodyWriter.WriteAsync(sequence.First).DefaultTimeout();

Circuits\RemoteJSDataStream.cs (1)

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

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

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

Internal\ServerSentEventsTransport.cs (1)

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

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

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

HttpConnectionDispatcherTests.cs (16)

LongPollingTests.cs (4)

75await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello World")); 98await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello")); 99await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes(" ")); 100await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("World"));

ServerSentEventsTests.cs (3)

76await connection.Transport.Output.WriteAsync(Encoding.ASCII.GetBytes("Hello")); 101await connection.Transport.Output.WriteAsync(Encoding.ASCII.GetBytes(hText + wText)); 124await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes(message));

WebSocketsTests.cs (1)

95await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello"));

Features\FormFeatureTests.cs (1)

93await pipe.Writer.WriteAsync(formContent);

Extensions\OpenApiEndpointRouteBuilderExtensions.cs (1)

54await context.Response.BodyWriter.WriteAsync(output.ToArray(), context.RequestAborted);

RecyclableReadOnlySequenceSegment.cs (2)

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

TestUtils.cs (1)

379await destination.WriteAsync(data, cancellationToken);

ResponseCachingBenchmark.cs (1)

37await context.Response.BodyWriter.WriteAsync(new ReadOnlyMemory<byte>(_data, 0, Size));

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

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

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

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

Internal\Http2\Http2Connection.cs (1)

543await _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\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

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

BodyControlTests.cs (1)

137await Assert.ThrowsAsync<ObjectDisposedException>(async () => await responsePipe.WriteAsync(new Memory<byte>()));

Http1\Http1ConnectionTests.cs (37)

HttpResponsePipeWriterTests.cs (1)

69var ex = Assert.Throws<ObjectDisposedException>(() => { pipeWriter.WriteAsync(new Memory<byte>()); });

MessageBodyTests.cs (1)

1245await input.Application.Output.WriteAsync(new byte[] { 0 });

TestHelpers\TestInput.cs (1)

63async Task Write() => await Application.Output.WriteAsync(data);

InMemoryTransportBenchmark.cs (1)

188return Input.WriteAsync(request);

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

49return _inner.WriteAsync(source, cancellationToken);

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

49return _inner.WriteAsync(source, cancellationToken);

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

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

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

167writeTask = _writer.WriteAsync(messageBytes, cancellationToken); 172writeTask = _writer.WriteAsync(messageBytes, cancellationToken); 279finalResult = await _writer.WriteAsync(item.HubMessage).ConfigureAwait(false);

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

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

HttpConnectionTests.ConnectionLifecycle.cs (1)

315await connection.Transport.Output.WriteAsync(new byte[] { 0x42 }).DefaultTimeout();

HttpConnectionTests.Transport.cs (10)

70await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 1")); 71await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 2")); 146await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello World")); 186await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello World")); 246await connection.Transport.Output.WriteAsync(data).DefaultTimeout(); 262() => connection.Transport.Output.WriteAsync(new byte[0]).DefaultTimeout()); 278() => connection.Transport.Output.WriteAsync(new byte[0]).DefaultTimeout()); 412await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 1")); 507await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 1")); 550await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 1"));

HubConnectionTests.ConnectionLifecycle.cs (1)

626await innerConnection.Application.Output.WriteAsync(Encoding.UTF8.GetBytes(new[] { '{' })).DefaultTimeout();

HubConnectionTests.Reconnect.cs (1)

920await currentTestConnection.Application.Output.WriteAsync(output.ToArray()).DefaultTimeout();

TestConnection.cs (3)

99await Application.Output.WriteAsync(response); 109return Application.Output.WriteAsync(bytes).AsTask(); 119return Application.Output.WriteAsync(bytes).AsTask();

HubConnectionContext.cs (2)

310return _connectionContext.Transport.Output.WriteAsync(buffer, cancellationToken); 418await _connectionContext.Transport.Output.WriteAsync(_cachedPingMessage);

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

167writeTask = _writer.WriteAsync(messageBytes, cancellationToken); 172writeTask = _writer.WriteAsync(messageBytes, cancellationToken); 279finalResult = await _writer.WriteAsync(item.HubMessage).ConfigureAwait(false);

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

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

AuthConnectionHandler.cs (1)

23await connection.Transport.Output.WriteAsync(buffer.ToArray());

EchoConnectionHandler.cs (1)

21await connection.Transport.Output.WriteAsync(buffer.ToArray());

EndToEndTests.cs (3)

193await connection.Transport.Output.WriteAsync(message).DefaultTimeout(); 279await connection.Transport.Output.WriteAsync(bytes).DefaultTimeout(); 336await connection.Transport.Output.WriteAsync(bytes).DefaultTimeout();

HttpHeaderConnectionHandler.cs (1)

30await connection.Transport.Output.WriteAsync(data);

HubConnectionHandlerTests.cs (12)

WriteThenCloseConnectionHandler.cs (1)

19await connection.Transport.Output.WriteAsync(buffer.ToArray());

TestClient.cs (2)

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

ResponseBodyWriterStream.cs (2)

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

PagedByteBuffer.cs (1)

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

FormPipeReaderTests.cs (3)

196await bodyPipe.Writer.WriteAsync(Encoding.UTF8.GetBytes(content1)); 202await bodyPipe.Writer.WriteAsync(Encoding.UTF8.GetBytes(content2)); 632await bodyPipe.Writer.WriteAsync(formContent);

Startup.cs (1)

32return response.BodyWriter.WriteAsync(payload).GetAsTask();

EchoConnectionHandler.cs (1)

22await connection.Transport.Output.WriteAsync(buffer.ToArray());

ConnectionHandlers\MessagesConnectionHandler.cs (1)

68tasks.Add(c.Transport.Output.WriteAsync(payload).AsTask());

PersistentConnectionLifeTimeManager.cs (1)

50await connection.Transport.Output.WriteAsync(ms.ToArray());

src\Servers\Kestrel\test\FunctionalTests\ResponseTests.cs (6)

72await context.Response.BodyWriter.WriteAsync(new Memory<byte>(bytes, 0, bytes.Length)); 309await context.Response.BodyWriter.WriteAsync(new Memory<byte>(scratchBuffer, 0, scratchBuffer.Length), context.RequestAborted); 523await context.Response.BodyWriter.WriteAsync(new Memory<byte>(chunkData, 0, chunkData.Length), context.RequestAborted); 659await context.Response.BodyWriter.WriteAsync(new Memory<byte>(chunkData, 0, chunkData.Length), context.RequestAborted); 869await context.Response.BodyWriter.WriteAsync(new Memory<byte>(chunkData, 0, chunkData.Length), context.RequestAborted); 1030await context.Response.BodyWriter.WriteAsync(new Memory<byte>(chunkData, 0, chunkData.Length), context.RequestAborted);

src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (1)

63await connection.Transport.Output.WriteAsync(result.Buffer.ToArray());

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

192(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)

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

Program.cs (2)

134await outputPipe.WriteAsync(outputMemory); 148await stream.Transport.Output.WriteAsync(new("Created a new stream from the client and sent this message then closing the stream."u8.ToArray()));