8 overrides of WriteAsync
InMemory.FunctionalTests (1)
src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)
47public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)
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.Microbenchmarks (1)
src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)
47public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
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)
251 references to WriteAsync
Aspire.Hosting.Tests (2)
Dcp\ApplicationExecutorTests.cs (2)
485await pipes.StandardOut.Writer.WriteAsync(Encoding.UTF8.GetBytes("2024-08-19T06:10:33.473275911Z Hello world" + Environment.NewLine)); 496await pipes.StandardErr.Writer.WriteAsync(Encoding.UTF8.GetBytes("2024-08-19T06:10:32.661Z Next" + Environment.NewLine));
ClientSample (1)
RawSample.cs (1)
106await output.WriteAsync(Encoding.UTF8.GetBytes(result));
CustomAuthorizationFailureResponse (1)
Authorization\SampleAuthorizationMiddlewareResultHandler.cs (1)
58httpContext.Response.OnStarting(() => httpContext.Response.BodyWriter.WriteAsync(Encoding.UTF8.GetBytes(message)).AsTask());
http2cat (2)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
98return _output.WriteAsync(buffer.AsMemory(offset, count), cancellationToken).GetAsTask(); 103return _output.WriteAsync(source, cancellationToken).GetAsValueTask();
IIS.FunctionalTests (2)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
98return _output.WriteAsync(buffer.AsMemory(offset, count), cancellationToken).GetAsTask(); 103return _output.WriteAsync(source, cancellationToken).GetAsValueTask();
IIS.LongTests (2)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
98return _output.WriteAsync(buffer.AsMemory(offset, count), cancellationToken).GetAsTask(); 103return _output.WriteAsync(source, cancellationToken).GetAsValueTask();
IIS.NewHandler.FunctionalTests (2)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
98return _output.WriteAsync(buffer.AsMemory(offset, count), cancellationToken).GetAsTask(); 103return _output.WriteAsync(source, cancellationToken).GetAsValueTask();
IIS.NewShim.FunctionalTests (2)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
98return _output.WriteAsync(buffer.AsMemory(offset, count), cancellationToken).GetAsTask(); 103return _output.WriteAsync(source, cancellationToken).GetAsValueTask();
IIS.ShadowCopy.Tests (2)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
98return _output.WriteAsync(buffer.AsMemory(offset, count), cancellationToken).GetAsTask(); 103return _output.WriteAsync(source, cancellationToken).GetAsValueTask();
IISExpress.FunctionalTests (2)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
98return _output.WriteAsync(buffer.AsMemory(offset, count), cancellationToken).GetAsTask(); 103return _output.WriteAsync(source, cancellationToken).GetAsValueTask();
InMemory.FunctionalTests (67)
ChunkedRequestTests.cs (4)
51await response.BodyWriter.WriteAsync(readResult.Buffer.ToArray()); 931await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 983await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 1094await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11));
ChunkedResponseTests.cs (16)
27await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello "), 0, 6)); 28await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("World!"), 0, 6)); 91await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello "), 0, 6)); 92await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("World!"), 0, 6)); 317await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello "), 0, 6)); 318await response.BodyWriter.WriteAsync(new Memory<byte>(new byte[0], 0, 0)); 319await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("World!"), 0, 6)); 397await response.BodyWriter.WriteAsync(new Memory<byte>(new byte[0], 0, 0)); 427await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World!"), 0, 12)); 460await response.BodyWriter.WriteAsync(new Memory<byte>(new byte[0], 0, 0)); 494await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello "), 0, 6)); 499await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("World!"), 0, 6)); 540await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("6\r\nHello \r\n"), 0, 11)); 541await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("6\r\nWorld!\r\n"), 0, 11)); 542await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("0\r\n\r\n"), 0, 5)); 1159await response.BodyWriter.WriteAsync(Encoding.ASCII.GetBytes("hello, world"));
ConnectionMiddlewareTests.cs (2)
309await context.Response.BodyWriter.WriteAsync(Encoding.ASCII.GetBytes("Hello ")); 311await context.Response.BodyWriter.WriteAsync(Encoding.ASCII.GetBytes("World!"));
Http2\Http2ConnectionTests.cs (1)
1399await context.Response.BodyWriter.WriteAsync(readResult.Buffer.ToArray());
Http2\Http2StreamTests.cs (5)
4300var result = await httpContext.Response.BodyWriter.WriteAsync(payload); 4333var cancelledResult = await httpContext.Response.BodyWriter.WriteAsync(payload); 4337var goodResult = await httpContext.Response.BodyWriter.WriteAsync(secondPayload); 4386await response.BodyWriter.WriteAsync(Encoding.ASCII.GetBytes("hello, world")); 4586await 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()); 534await context.Response.BodyWriter.WriteAsync(new byte[1] { 0x02 });
Http3\Http3StreamTests.cs (4)
729await context.Response.BodyWriter.WriteAsync(new byte[] { data[i] }); 768var result = await context.Response.BodyWriter.WriteAsync(payload); 799var cancelledResult = await context.Response.BodyWriter.WriteAsync(payload); 803var goodResult = await context.Response.BodyWriter.WriteAsync(secondPayload);
Http3\WebTransport\WebTransportStreamTests.cs (1)
42await stream.Transport.Output.WriteAsync(input, CancellationToken.None);
KestrelMetricsTests.cs (1)
286await c.Response.BodyWriter.WriteAsync(Encoding.UTF8.GetBytes("Hello world"));
RequestTests.cs (3)
1923await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 1969await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 2052await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11));
ResponseTests.cs (25)
161var writeTask = context.Response.BodyWriter.WriteAsync(new Memory<byte>(data, 0, data.Length), cts.Token).AsTask().DefaultTimeout(); 168writeTask = context.Response.BodyWriter.WriteAsync(new Memory<byte>(data, 0, data.Length), cts.Token).AsTask().DefaultTimeout(); 223var result = await context.Response.BodyWriter.WriteAsync(payload); 250var cancelledResult = await context.Response.BodyWriter.WriteAsync(payload); 254var goodResult = await context.Response.BodyWriter.WriteAsync(secondPayload); 960await httpContext.Response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("hello,"), 0, 6)); 961await httpContext.Response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes(" world"), 0, 6)); 1041await httpContext.Response.BodyWriter.WriteAsync(new Memory<byte>(response, 0, response.Length)); 1076await httpContext.Response.BodyWriter.WriteAsync(new Memory<byte>(response, 0, response.Length)); 1474await httpContext.Response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("hello, world"), 0, 12)); 1724await httpContext.Response.BodyWriter.WriteAsync(new Memory<byte>(response, 0, response.Length)); 1808await httpContext.Response.BodyWriter.WriteAsync(new Memory<byte>(response, 0, response.Length / 2)); 1809await httpContext.Response.BodyWriter.WriteAsync(new Memory<byte>(response, response.Length / 2, response.Length - response.Length / 2)); 1896return httpContext.Response.BodyWriter.WriteAsync(new Memory<byte>(response, 0, response.Length)).AsTask(); 1936await httpContext.Response.BodyWriter.WriteAsync(new Memory<byte>(response, 0, response.Length / 2)); 1937await httpContext.Response.BodyWriter.WriteAsync(new Memory<byte>(response, response.Length / 2, response.Length - response.Length / 2)); 2551await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 2597await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 2644await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 2690await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 2735await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello"), 0, 5)); 2770await response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello World"), 0, 11)); 3523return context.Response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello!"), 0, 6)).AsTask(); 3787await response.BodyWriter.WriteAsync(Encoding.ASCII.GetBytes("hello, world\r\n")); 4340await httpContext.Response.BodyWriter.WriteAsync(new byte[1]);
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());
Interop.FunctionalTests (3)
Http3\Http3RequestTests.cs (1)
1357await context.Response.BodyWriter.WriteAsync(TestData);
HttpClientHttp2InteropTests.cs (2)
282await context.Response.BodyWriter.WriteAsync(sequence.First).DefaultTimeout(); 339await context.Response.BodyWriter.WriteAsync(sequence.First).DefaultTimeout();
Microsoft.AspNetCore.Components.Server (1)
Circuits\RemoteJSDataStream.cs (1)
125await _pipe.Writer.WriteAsync(chunk, _streamCancellationToken);
Microsoft.AspNetCore.Http.Connections (1)
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\SignalR\common\Shared\PipeWriterStream.cs (1)
76var task = _pipeWriter.WriteAsync(source, cancellationToken);
Microsoft.AspNetCore.Http.Connections.Tests (24)
HttpConnectionDispatcherTests.cs (16)
481await connectionContext.Transport.Output.WriteAsync(result.Buffer.First); 545await connectionContext.Transport.Output.WriteAsync(result.Buffer.First); 1297await connection.Transport.Output.WriteAsync(new byte[] { 1 }).DefaultTimeout(); 1336await connection.Transport.Output.WriteAsync(new byte[] { 1 }).DefaultTimeout(); 1380await connection.Transport.Output.WriteAsync(new byte[] { 1 }).DefaultTimeout(); 1658await connection.Transport.Output.WriteAsync(buffer); 1775await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello, World")); 1863await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Unblock")).AsTask().DefaultTimeout(); 1915await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Unblock")).AsTask().DefaultTimeout(); 2223await c.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Message1")).DefaultTimeout(); 2226await c.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Message2")).DefaultTimeout(); 3862await connection.Transport.Output.WriteAsync(result.Buffer.ToArray()); 3920await connection.Transport.Output.WriteAsync(message.Buffer.ToArray()); 3947await connection.Transport.Output.WriteAsync(result.Buffer.ToArray()); 3974await connection.Transport.Output.WriteAsync(result.Buffer.ToArray()); 4022await _writer.WriteAsync(res.Buffer.ToArray());
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"));
Microsoft.AspNetCore.Http.Tests (1)
Features\FormFeatureTests.cs (1)
93await pipe.Writer.WriteAsync(formContent);
Microsoft.AspNetCore.OpenApi (1)
Extensions\OpenApiEndpointRouteBuilderExtensions.cs (1)
68await context.Response.BodyWriter.WriteAsync(output.ToArray(), context.RequestAborted);
Microsoft.AspNetCore.OutputCaching (2)
RecyclableReadOnlySequenceSegment.cs (2)
108await destination.WriteAsync(source.First, cancellationToken); 116await destination.WriteAsync(segment, cancellationToken);
Microsoft.AspNetCore.OutputCaching.Tests (1)
TestUtils.cs (1)
380await destination.WriteAsync(data, cancellationToken);
Microsoft.AspNetCore.ResponseCaching.Microbenchmarks (1)
ResponseCachingBenchmark.cs (1)
37await context.Response.BodyWriter.WriteAsync(new ReadOnlyMemory<byte>(_data, 0, Size));
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (2)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
98return _output.WriteAsync(buffer.AsMemory(offset, count), cancellationToken).GetAsTask(); 103return _output.WriteAsync(source, cancellationToken).GetAsValueTask();
Microsoft.AspNetCore.Server.IIS (2)
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)
593await _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();
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (41)
BodyControlTests.cs (1)
137await Assert.ThrowsAsync<ObjectDisposedException>(async () => await responsePipe.WriteAsync(new Memory<byte>()));
Http1\Http1ConnectionTests.cs (37)
32await _application.Output.WriteAsync(Encoding.UTF8.GetBytes($"{headerName}: ")); 33await _application.Output.WriteAsync(headerValueBytes); 34await _application.Output.WriteAsync(Encoding.UTF8.GetBytes("\r\n\r\n")); 51await _application.Output.WriteAsync(extendedAsciiEncoding.GetBytes($"{headerName}: ")); 52await _application.Output.WriteAsync(headerValueBytes); 53await _application.Output.WriteAsync(extendedAsciiEncoding.GetBytes("\r\n\r\n")); 66await _application.Output.WriteAsync(Encoding.ASCII.GetBytes($"{headerLine}\r\n")); 77await _application.Output.WriteAsync(Encoding.ASCII.GetBytes($"{headerLine}\r\n")); 94await _application.Output.WriteAsync(Encoding.ASCII.GetBytes($"{headerLines}\r\n")); 120await _application.Output.WriteAsync(Encoding.ASCII.GetBytes($"{startLine}")); 135await _application.Output.WriteAsync(Encoding.ASCII.GetBytes($"{headerLine}\r\n")); 195await _application.Output.WriteAsync(data); 273await _application.Output.WriteAsync(Encoding.ASCII.GetBytes($"{headerLine1}\r\n")); 285await _application.Output.WriteAsync(Encoding.ASCII.GetBytes($"{headerLine2}\r\n")); 410await _application.Output.WriteAsync(requestLineBytes); 433await _application.Output.WriteAsync(requestLineBytes); 448await _application.Output.WriteAsync(Encoding.ASCII.GetBytes("G")); 462await _application.Output.WriteAsync(requestLineBytes); 476await _application.Output.WriteAsync(Encoding.ASCII.GetBytes($"GET {target} HTTP/1.1\r\n")); 490await _application.Output.WriteAsync(Encoding.ASCII.GetBytes($"GET {target} HTTP/1.1\r\n")); 507await _application.Output.WriteAsync(Encoding.ASCII.GetBytes(requestLine)); 524await _application.Output.WriteAsync(Encoding.ASCII.GetBytes($"GET {target} HTTP/1.1\r\n")); 541await _application.Output.WriteAsync(Encoding.ASCII.GetBytes(requestLine)); 556await _application.Output.WriteAsync(Encoding.ASCII.GetBytes(requestLine)); 661await _application.Output.WriteAsync(data); 720var successResult = await writer.WriteAsync(payload); 734var successResult = await writer.WriteAsync(payload); 845await _application.Output.WriteAsync(Encoding.ASCII.GetBytes($"GET /%00 HTTP/1.1\r\n")); 877await _application.Output.WriteAsync(Encoding.ASCII.GetBytes("GET / HTTP/1.0\r\n")); 881await _application.Output.WriteAsync(Encoding.ASCII.GetBytes(headers0)); 885await _application.Output.WriteAsync(Encoding.ASCII.GetBytes(headers1)); 889await _application.Output.WriteAsync(Encoding.ASCII.GetBytes("\r\n")); 909await _application.Output.WriteAsync(Encoding.ASCII.GetBytes("GET / HTTP/1.0\r\n")); 917await _application.Output.WriteAsync(Encoding.ASCII.GetBytes(headers0)); 922await _application.Output.WriteAsync(Encoding.ASCII.GetBytes(headers1)); 927await _application.Output.WriteAsync(Encoding.ASCII.GetBytes("\r\n")); 966await _application.Output.WriteAsync(data);
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)
68async Task Write() => await Application.Output.WriteAsync(data);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (2)
InMemoryTransportBenchmark.cs (1)
188return Input.WriteAsync(request);
src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)
49return _inner.WriteAsync(source, cancellationToken);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)
49return _inner.WriteAsync(source, cancellationToken);
Microsoft.AspNetCore.Shared.Tests (2)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
98return _output.WriteAsync(buffer.AsMemory(offset, count), cancellationToken).GetAsTask(); 103return _output.WriteAsync(source, cancellationToken).GetAsValueTask();
Microsoft.AspNetCore.SignalR.Client.Core (4)
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);
Microsoft.AspNetCore.SignalR.Client.Tests (16)
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();
Microsoft.AspNetCore.SignalR.Core (5)
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);
Microsoft.AspNetCore.SignalR.Specification.Tests (2)
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (2)
75await Connection.Application.Output.WriteAsync(GetHandshakeRequestMessage()); 236await Connection.Application.Output.WriteAsync(payload);
Microsoft.AspNetCore.SignalR.Tests (19)
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)
354await client.Connection.Application.Output.WriteAsync(part1); 358await client.Connection.Application.Output.WriteAsync(part2); 362await client.Connection.Application.Output.WriteAsync(part3); 395await client.Connection.Application.Output.WriteAsync(part1); 399await client.Connection.Application.Output.WriteAsync(part2); 403await client.Connection.Application.Output.WriteAsync(part3); 436await client.Connection.Application.Output.WriteAsync(payload); 491await client.Connection.Application.Output.WriteAsync(payload); 520await client.Connection.Application.Output.WriteAsync(payload.AsMemory(0, payload.Length / 2)); 521await client.Connection.Application.Output.WriteAsync(payload.AsMemory(payload.Length / 2)); 669await client.Connection.Application.Output.WriteAsync(payload).DefaultTimeout(); 3566await client.Connection.Application.Output.WriteAsync(Encoding.UTF8.GetBytes(new[] { '{' })).DefaultTimeout();
WriteThenCloseConnectionHandler.cs (1)
19await connection.Transport.Output.WriteAsync(buffer.ToArray());
Microsoft.AspNetCore.SignalR.Tests.Utils (2)
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);
Microsoft.AspNetCore.WebUtilities.Tests (3)
FormPipeReaderTests.cs (3)
196await bodyPipe.Writer.WriteAsync(Encoding.UTF8.GetBytes(content1)); 202await bodyPipe.Writer.WriteAsync(Encoding.UTF8.GetBytes(content2)); 632await bodyPipe.Writer.WriteAsync(formContent);
PlaintextApp (1)
Startup.cs (1)
32return response.BodyWriter.WriteAsync(payload).GetAsTask();
SignalR.Client.FunctionalTestApp (1)
EchoConnectionHandler.cs (1)
22await connection.Transport.Output.WriteAsync(buffer.ToArray());
SignalRSamples (1)
ConnectionHandlers\MessagesConnectionHandler.cs (1)
68tasks.Add(c.Transport.Output.WriteAsync(payload).AsTask());
SocialWeather (1)
PersistentConnectionLifeTimeManager.cs (1)
50await connection.Transport.Output.WriteAsync(ms.ToArray());
Sockets.FunctionalTests (7)
src\Servers\Kestrel\test\FunctionalTests\ResponseTests.cs (6)
65await 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); 535await context.Response.BodyWriter.WriteAsync(new Memory<byte>(chunkData, 0, chunkData.Length), context.RequestAborted); 673await context.Response.BodyWriter.WriteAsync(new Memory<byte>(chunkData, 0, chunkData.Length), context.RequestAborted); 888await context.Response.BodyWriter.WriteAsync(new Memory<byte>(chunkData, 0, chunkData.Length), context.RequestAborted); 1052await 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 (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)
339FlushResult flushResult = await destination.WriteAsync(segment.Memory.Slice(segmentIndex), tokenSource.Token).ConfigureAwait(false);
WebTransportInteractiveSampleApp (2)
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()));