15 overrides of ReadAsync
InMemory.FunctionalTests (4)
Http3\WebTransport\WebTransportTestUtilities.cs (1)
190public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
52public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
78public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => _input.ReadAsync(cancellationToken);
TestTransport\InMemoryTransportConnection.cs (1)
147public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http\HttpRequestPipeReader.cs (1)
59public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
78public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => _input.ReadAsync(cancellationToken);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
52public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
52public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
Shared\TestPipeReader.cs (1)
35public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = new CancellationToken())
Microsoft.AspNetCore.SignalR.Tests (1)
HubConnectionHandlerTests.cs (1)
2956public override async ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)
Sockets.FunctionalTests (2)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
78public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => _input.ReadAsync(cancellationToken);
src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (1)
117public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)
System.IO.Pipelines (3)
System\IO\Pipelines\Pipe.DefaultPipeReader.cs (1)
24public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => _pipe.ReadAsync(cancellationToken);
System\IO\Pipelines\SequencePipeReader.cs (1)
62public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)
System\IO\Pipelines\StreamPipeReader.cs (1)
201public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)
268 references to ReadAsync
Aspire.Dashboard (1)
Otlp\Http\OtlpHttpEndpointsBuilder.cs (1)
184result = await httpContext.Request.BodyReader.ReadAsync().ConfigureAwait(false);
Aspire.Hosting (1)
Dcp\DcpHostService.cs (1)
354var result = await reader.ReadAsync(CancellationToken.None).ConfigureAwait(false);
ClientSample (2)
RawSample.cs (1)
79var result = await input.ReadAsync();
Tcp\TcpConnection.cs (1)
221var result = await _application.Input.ReadAsync();
http2cat (1)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)
121var result = await _input.ReadAsync(cancellationToken);
IIS.FunctionalTests (1)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)
121var result = await _input.ReadAsync(cancellationToken);
IIS.LongTests (1)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)
121var result = await _input.ReadAsync(cancellationToken);
IIS.NewHandler.FunctionalTests (1)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)
121var result = await _input.ReadAsync(cancellationToken);
IIS.NewShim.FunctionalTests (1)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)
121var result = await _input.ReadAsync(cancellationToken);
IIS.ShadowCopy.Tests (1)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)
121var result = await _input.ReadAsync(cancellationToken);
IISExpress.FunctionalTests (1)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)
121var result = await _input.ReadAsync(cancellationToken);
InMemory.FunctionalTests (53)
ChunkedRequestTests.cs (8)
45var readResult = await request.BodyReader.ReadAsync(); 389var result = await request.BodyReader.ReadAsync(); 918var readResult = await request.BodyReader.ReadAsync(); 921var requestTask = httpContext.Request.BodyReader.ReadAsync(); 974var readResult = await request.BodyReader.ReadAsync(); 979await Assert.ThrowsAsync<InvalidOperationException>(async () => await request.BodyReader.ReadAsync()); 1024var readResult = await request.BodyReader.ReadAsync(); 1087var readResult = await request.BodyReader.ReadAsync();
Http2\Http2ConnectionTests.cs (4)
1387var readResult = await context.Request.BodyReader.ReadAsync(); 1391readResult = await context.Request.BodyReader.ReadAsync(); 1396readResult = await context.Request.BodyReader.ReadAsync(); 5660var result = await context.Request.BodyReader.ReadAsync().DefaultTimeout();
Http2\Http2StreamTests.cs (10)
998var readResult = await context.Request.BodyReader.ReadAsync(); 1002readResult = await context.Request.BodyReader.ReadAsync(); 1042var readResult = await context.Request.BodyReader.ReadAsync(); 1281var readResult = await context.Request.BodyReader.ReadAsync(); 1285readResult = await context.Request.BodyReader.ReadAsync(); 1291readResult = await context.Request.BodyReader.ReadAsync(); 5527var requestBodyTask = context.Request.BodyReader.ReadAsync(); 5546await Assert.ThrowsAsync<ConnectionAbortedException>(async () => await context.Request.BodyReader.ReadAsync()); 5693var requestBodyTask = context.Request.BodyReader.ReadAsync(); 5714await Assert.ThrowsAsync<ConnectionAbortedException>(async () => await context.Request.BodyReader.ReadAsync());
Http2\TlsTests.cs (1)
109var result = await reader.ReadAsync();
Http3\Http3StreamTests.cs (6)
622var readResult = await context.Request.BodyReader.ReadAsync(); 626readResult = await context.Request.BodyReader.ReadAsync(); 1769var requestBodyTask = context.Request.BodyReader.ReadAsync(); 1788await Assert.ThrowsAsync<ConnectionAbortedException>(async () => await context.Request.BodyReader.ReadAsync()); 1896var requestBodyTask = context.Request.BodyReader.ReadAsync(); 1917await Assert.ThrowsAsync<ConnectionAbortedException>(async () => await context.Request.BodyReader.ReadAsync());
KestrelMetricsTests.cs (1)
173var result = await context.Request.BodyReader.ReadAsync();
RequestTests.cs (20)
96var data = await context.Request.BodyReader.ReadAsync(); 970var readResult = await httpContext.Request.BodyReader.ReadAsync().AsTask().DefaultTimeout(); 1017var readResult = await httpContext.Request.BodyReader.ReadAsync(); 1049var readResult = await httpContext.Request.BodyReader.ReadAsync(); 1053readResult = await httpContext.Request.BodyReader.ReadAsync(); 1084var readResult = await httpContext.Request.BodyReader.ReadAsync(); 1091readResult = await httpContext.Request.BodyReader.ReadAsync(); 1165var result = await reader.ReadAsync(); 1170result = await reader.ReadAsync(); 1191readResult = await httpContext.Request.BodyReader.ReadAsync(); 1196readResult = await httpContext.Request.BodyReader.ReadAsync(); 1201readResult = await httpContext.Request.BodyReader.ReadAsync(); 1238var readResult = await httpContext.Request.BodyReader.ReadAsync(); 1242readResult = await httpContext.Request.BodyReader.ReadAsync(); 1910var readResult = await request.BodyReader.ReadAsync(); 1913var requestTask = httpContext.Request.BodyReader.ReadAsync(); 1960var readResult = await request.BodyReader.ReadAsync(); 1965await Assert.ThrowsAsync<InvalidOperationException>(async () => await request.BodyReader.ReadAsync()); 2002var readResult = await request.BodyReader.ReadAsync(); 2045var readResult = await request.BodyReader.ReadAsync();
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
54return _inner.ReadAsync(cancellationToken);
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
78public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => _input.ReadAsync(cancellationToken);
TestTransport\InMemoryTransportConnection.cs (1)
149var task = _reader.ReadAsync(cancellationToken);
Interop.FunctionalTests (8)
HttpClientHttp2InteropTests.cs (8)
273var readResult = await reader.ReadAsync().DefaultTimeout(); 277readResult = await reader.ReadAsync().DefaultTimeout(); 286var finalResult = await reader.ReadAsync().DefaultTimeout(); 330var readResult = await reader.ReadAsync().DefaultTimeout(); 334readResult = await reader.ReadAsync().DefaultTimeout(); 346readResult = await reader.ReadAsync().DefaultTimeout(); 350readResult = await reader.ReadAsync().DefaultTimeout(); 357var finalResult = await reader.ReadAsync().DefaultTimeout();
Microsoft.AspNetCore.Grpc.JsonTranscoding.Tests (1)
ServerStreamingServerCallHandlerTests.cs (1)
267var result = await pipeReader.ReadAsync();
Microsoft.AspNetCore.Http.Connections (3)
Internal\Transports\LongPollingServerTransport.cs (1)
36var result = await _application.ReadAsync(token);
Internal\Transports\ServerSentEventsServerTransport.cs (1)
51var result = await _application.ReadAsync(cancellationToken);
Internal\Transports\WebSocketsServerTransport.cs (1)
208var result = await _application.Input.ReadAsync();
Microsoft.AspNetCore.Http.Connections.Client (2)
Internal\SendUtils.cs (1)
27var result = await application.Input.ReadAsync(cancellationToken).ConfigureAwait(false);
Internal\WebSocketsTransport.cs (1)
540var result = await _application.Input.ReadAsync().ConfigureAwait(false);
Microsoft.AspNetCore.Http.Connections.Tests (15)
HttpConnectionDispatcherTests.cs (9)
479var result = await connectionContext.Transport.Input.ReadAsync(); 543var result = await connectionContext.Transport.Input.ReadAsync(); 3817var result = connection.Transport.Input.ReadAsync().AsTask().Result; 3845var result = await connection.Transport.Input.ReadAsync(); 3884var result = await connection.Transport.Input.ReadAsync(); 3907var result = await connection.Transport.Input.ReadAsync(); 3937var result = await connection.Transport.Input.ReadAsync(); 3964var result = await connection.Transport.Input.ReadAsync(); 4013var res = await connection.Transport.Input.ReadAsync(connection.ConnectionClosed);
HttpConnectionManagerTests.cs (3)
109var result = await connection.Transport.Input.ReadAsync(); 134var exception = await Assert.ThrowsAsync<InvalidOperationException>(async () => await connection.Transport.Input.ReadAsync()); 251var result = await connection.Transport.Input.ReadAsync();
MapConnectionHandlerTests.cs (1)
436var result = await connection.Transport.Input.ReadAsync();
WebSocketsTests.cs (2)
54var result = await connection.Transport.Input.ReadAsync(); 132var result = await connection.Transport.Input.ReadAsync();
Microsoft.AspNetCore.Http.Extensions.Tests (4)
RequestDelegateGenerator\RequestDelegateCreationTests.JsonBody.cs (4)
249var result = await httpContext.Request.BodyReader.ReadAsync(); 290var result = await httpContext.Request.BodyReader.ReadAsync(); 331var result = await httpContext.Request.BodyReader.ReadAsync(); 372var result = await httpContext.Request.BodyReader.ReadAsync();
Microsoft.AspNetCore.Http.Tests (2)
Features\RequestBodyPipeFeatureTests.cs (2)
37var data = await feature.Reader.ReadAsync(); 58var data = await feature.Reader.ReadAsync();
Microsoft.AspNetCore.OutputCaching.Tests (1)
CachedResponseBodyTests.cs (1)
100var result = await reader.ReadAsync(cancellationToken);
Microsoft.AspNetCore.ResponseCaching.Microbenchmarks (1)
ResponseCachingBenchmark.cs (1)
98var result = await reader.ReadAsync(cancellationToken);
Microsoft.AspNetCore.ResponseCaching.Tests (1)
CachedResponseBodyTests.cs (1)
105var result = await reader.ReadAsync(cancellationToken);
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (1)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)
121var result = await _input.ReadAsync(cancellationToken);
Microsoft.AspNetCore.Server.IIS (3)
Core\IISHttpContext.IO.cs (2)
30var result = await _bodyInputPipe!.Reader.ReadAsync(cancellationToken); 163var result = await _bodyOutput.Reader.ReadAsync();
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)
121var result = await _input.ReadAsync(cancellationToken);
Microsoft.AspNetCore.Server.Kestrel.Core (19)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (3)
65var readAwaitable = _requestBodyPipe.Reader.ReadAsync(cancellationToken); 97var awaitable = _context.Input.ReadAsync(); 149awaitable = _context.Input.ReadAsync();
Internal\Http\Http1Connection.cs (1)
717awaitable = Input.ReadAsync();
Internal\Http\Http1ContentLengthMessageBody.cs (1)
59var readAwaitable = _context.Input.ReadAsync(cancellationToken);
Internal\Http\Http1UpgradeMessageBody.cs (2)
80var readTask = _context.Input.ReadAsync(cancellationToken); 101readResult = await _context.Input.ReadAsync(cancellationToken);
Internal\Http2\Http2Connection.cs (3)
320var result = await Input.ReadAsync(); 553var result = await Input.ReadAsync(); 1857var readResult = await reader.ReadAsync();
Internal\Http2\Http2MessageBody.cs (1)
111var readAwaitable = _context.RequestBodyPipe.Reader.ReadAsync(cancellationToken);
Internal\Http3\Http3ControlStream.cs (3)
153var result = await Input.ReadAsync(); 252var result = await Input.ReadAsync(); 291var result = await Input.ReadAsync();
Internal\Http3\Http3MessageBody.cs (1)
79var readAwaitable = _context.RequestBodyPipe.Reader.ReadAsync(cancellationToken);
Internal\Http3\Http3OutputProducer.cs (1)
421readResult = await _pipeReader.ReadAsync();
Internal\Http3\Http3PendingStream.cs (1)
50var result = await Input.ReadAsync();
Internal\Http3\Http3Stream.cs (1)
614var result = await Input.ReadAsync();
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)
121var result = await _input.ReadAsync(cancellationToken);
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (54)
BodyControlTests.cs (4)
31await Assert.ThrowsAsync<Exception>(async () => await requestPipe.ReadAsync())); 54await Assert.ThrowsAsync<Exception>(async () => await requestPipe.ReadAsync())); 79await Assert.ThrowsAsync<Exception>(async () => await requestPipe.ReadAsync())); 120await Assert.ThrowsAsync<ObjectDisposedException>(async () => await requestPipe.ReadAsync());
BufferWriterTests.cs (2)
29ReadResult readResult = Pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 202var readResult = Pipe.Reader.ReadAsync().GetAwaiter().GetResult();
Http1\Http1ConnectionTests.cs (21)
35var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 54var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 67var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 78var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 95var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 121var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 136readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 199var read = await _application.Input.ReadAsync(); 274var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 286readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 411var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 434var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 450ParseRequest((await _transport.Input.ReadAsync()).Buffer, out _consumed, out _examined); 464var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 477var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 491var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 508var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 525var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 542var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 557var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 846var readableBuffer = (await _transport.Input.ReadAsync()).Buffer;
Http2\Http2FrameWriterTests.cs (1)
104var result = await pipeReader.ReadAsync();
HttpRequestPipeReaderTests.cs (3)
21await Assert.ThrowsAsync<ObjectDisposedException>(async () => { await pipeReader.ReadAsync(); }); 30await Assert.ThrowsAsync<TaskCanceledException>(() => pipeReader.ReadAsync().AsTask()); 41var exception = await Assert.ThrowsAsync<Exception>(() => pipeReader.ReadAsync().AsTask());
MessageBodyTests.cs (15)
69var readResult = await reader.ReadAsync(); 75readResult = await reader.ReadAsync(); 123var readResult = await reader.ReadAsync(); 125await Assert.ThrowsAsync<InvalidOperationException>(async () => await reader.ReadAsync()); 987var readResultTask = reader.ReadAsync(); 1008var readResultTask = reader.ReadAsync(); 1029var readResultTask = reader.ReadAsync(); 1050var readResultTask = reader.ReadAsync(); 1223var ex2 = await Assert.ThrowsAsync<BadHttpRequestException>(() => reader.ReadAsync().AsTask()); 1224var ex3 = await Assert.ThrowsAsync<BadHttpRequestException>(() => reader.ReadAsync().AsTask()); 1247var readResult = await reader.ReadAsync(); 1256var ex2 = await Assert.ThrowsAsync<BadHttpRequestException>(() => reader.ReadAsync().AsTask()); 1257var ex3 = await Assert.ThrowsAsync<BadHttpRequestException>(() => reader.ReadAsync().AsTask()); 1283var ex2 = await Assert.ThrowsAsync<BadHttpRequestException>(() => reader.ReadAsync().AsTask()); 1284var ex3 = await Assert.ThrowsAsync<BadHttpRequestException>(() => reader.ReadAsync().AsTask());
PipelineExtensionTests.cs (7)
45var reader = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 62var readResult = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 88var reader = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 114var reader = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 142var reader = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 160var reader = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 193var reader = _pipe.Reader.ReadAsync().GetAwaiter().GetResult();
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
78public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => _input.ReadAsync(cancellationToken);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (10)
ChunkWriterBenchmark.cs (1)
39var result = await _reader.ReadAsync();
Http2\Http2ConnectionBenchmarkBase.cs (1)
156var result = await pipeReader.ReadAsync();
InMemoryTransportBenchmark.cs (2)
196var result = await Output.ReadAsync(); 213var result = await Output.ReadAsync();
PipeThroughputBenchmark.cs (2)
44var result = await _pipe.Reader.ReadAsync(); 61var result = _pipe.Reader.ReadAsync().GetAwaiter().GetResult();
RequestParsingBenchmark.cs (3)
141var awaitable = Pipe.Reader.ReadAsync(); 173var awaitable = Pipe.Reader.ReadAsync(); 192result = Pipe.Reader.ReadAsync().GetAwaiter().GetResult();
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
54return _inner.ReadAsync(cancellationToken);
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)
Internal\NamedPipeConnection.cs (1)
157var result = await Output.ReadAsync();
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (2)
Internal\QuicStreamContext.cs (1)
383var result = await output.ReadAsync();
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
54return _inner.ReadAsync(cancellationToken);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (2)
QuicConnectionContextTests.cs (1)
617readResult = await serverStream.Transport.Input.ReadAsync();
QuicTestHelpers.cs (1)
159readResult = await serverStream.Transport.Input.ReadAsync();
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (1)
Internal\SocketConnection.cs (1)
274var result = await Output.ReadAsync();
Microsoft.AspNetCore.Shared.Tests (1)
src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)
121var result = await _input.ReadAsync(cancellationToken);
Microsoft.AspNetCore.SignalR.Client.Core (2)
HubConnection.cs (2)
1510var result = await input.ReadAsync(linkedToken).ConfigureAwait(false); 1630var result = await input.ReadAsync().ConfigureAwait(false);
Microsoft.AspNetCore.SignalR.Client.Tests (3)
HttpConnectionTests.ConnectionLifecycle.cs (1)
317await Assert.ThrowsAsync<HttpRequestException>(async () => await connection.Transport.Input.ReadAsync());
TestConnection.cs (1)
148var result = await Application.Input.ReadAsync();
TestTransport.cs (1)
59var result = await Application.Input.ReadAsync();
Microsoft.AspNetCore.SignalR.Core (2)
HubConnectionContext.cs (1)
510var result = await input.ReadAsync();
HubConnectionHandler.cs (1)
273var result = await input.ReadAsync();
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
BroadcastBenchmark.cs (1)
78var result = await application.Input.ReadAsync();
Microsoft.AspNetCore.SignalR.Specification.Tests (1)
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (1)
248var result = await Connection.Application.Input.ReadAsync();
Microsoft.AspNetCore.SignalR.Tests (30)
AuthConnectionHandler.cs (1)
18var result = await connection.Transport.Input.ReadAsync();
EchoConnectionHandler.cs (1)
16var result = await connection.Transport.Input.ReadAsync();
HttpHeaderConnectionHandler.cs (1)
18var result = await connection.Transport.Input.ReadAsync();
HubConnectionHandlerTests.cs (1)
2965return await _originalPipeReader.ReadAsync(cancellationToken);
Internal\MessageBufferTests.cs (25)
34var res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 59var res = await pipes.Application.Input.ReadAsync(); 73res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 101var res = await pipes.Application.Input.ReadAsync(); 110res = await pipes.Application.Input.ReadAsync(); 134var res = await pipes.Application.Input.ReadAsync(); 149res = await pipes.Application.Input.ReadAsync(); 158res = await pipes.Application.Input.ReadAsync(); 183var res = await pipes.Application.Input.ReadAsync(); 196res = await pipes.Application.Input.ReadAsync(); 207res = await pipes.Application.Input.ReadAsync(); 228var res = await pipes.Application.Input.ReadAsync(); 260var res = await pipes.Application.Input.ReadAsync(); 271res = await pipes.Application.Input.ReadAsync(); 297var res = await pipes.Application.Input.ReadAsync(); 311res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 342var res = await pipes.Application.Input.ReadAsync(); 351res = await pipes.Application.Input.ReadAsync(); 378var res = await pipes.Application.Input.ReadAsync(); 390res = await pipes.Application.Input.ReadAsync(); 422var res = await pipes.Application.Input.ReadAsync(); 430res = await pipes.Application.Input.ReadAsync(); 469var res = await pipes.Application.Input.ReadAsync(); 479res = await pipes.Application.Input.ReadAsync(); 488res = await pipes.Application.Input.ReadAsync();
WriteThenCloseConnectionHandler.cs (1)
14var result = await connection.Transport.Input.ReadAsync();
Microsoft.AspNetCore.SignalR.Tests.Utils (6)
PipeReaderExtensions.cs (5)
14var result = await pipeReader.ReadAsync(); 40var result = await pipeReader.ReadAsync(); 57var result = await pipeReader.ReadAsync(); 73var result = await pipeReader.ReadAsync(); 89var result = await pipeReader.ReadAsync();
TestClient.cs (1)
248var result = await Connection.Application.Input.ReadAsync();
Microsoft.AspNetCore.TestHost (1)
ResponseBodyReaderStream.cs (1)
87var result = await _pipe.Reader.ReadAsync(cancellationToken);
Microsoft.AspNetCore.WebUtilities (1)
FormPipeReader.cs (1)
96var readResult = await _pipeReader.ReadAsync(cancellationToken);
Microsoft.AspNetCore.WebUtilities.Tests (5)
FormPipeReaderTests.cs (5)
113var readResult = await bodyPipe.ReadAsync(); 128var readResult = await bodyPipe.ReadAsync(); 156var readResult = await bodyPipe.ReadAsync(); 184var readResult = await bodyPipe.ReadAsync(); 209var readResult = await bodyPipe.Reader.ReadAsync();
SignalR.Client.FunctionalTestApp (1)
EchoConnectionHandler.cs (1)
15var result = await connection.Transport.Input.ReadAsync();
SignalRSamples (1)
ConnectionHandlers\MessagesConnectionHandler.cs (1)
27var result = await connection.Transport.Input.ReadAsync();
SocialWeather (1)
SocialWeatherConnectionHandler.cs (1)
37var result = await connection.Transport.Input.ReadAsync();
Sockets.FunctionalTests (2)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
78public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => _input.ReadAsync(cancellationToken);
src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (1)
55var result = await connection.Transport.Input.ReadAsync(notificationFeature.ConnectionClosedRequested);
System.IO.Pipelines (15)
System\IO\Pipelines\PipeReader.cs (6)
70ReadResult result = await ReadAsync(cancellationToken).ConfigureAwait(false); 86/// The <see cref="System.IO.Pipelines.ReadResult.Buffer" /> previously returned from <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> must not be accessed after this call. 96/// The <see cref="System.IO.Pipelines.ReadResult.Buffer" /> previously returned from <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> must not be accessed after this call. 117/// <summary>Cancels the pending <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> operation without causing it to throw and without completing the <see cref="System.IO.Pipelines.PipeReader" />. If there is no pending operation, this cancels the next operation.</summary> 118/// <remarks>The canceled <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> operation returns a <see cref="System.IO.Pipelines.ReadResult" /> where <see cref="System.IO.Pipelines.ReadResult.IsCanceled" /> is <see langword="true" />.</remarks> 236ReadResult result = await ReadAsync(cancellationToken).ConfigureAwait(false);
System\IO\Pipelines\PipeReaderStream.cs (2)
66ValueTask<ReadResult> vt = _pipeReader.ReadAsync(); 107ReadResult result = await _pipeReader.ReadAsync(cancellationToken).ConfigureAwait(false);
System\IO\Pipelines\PipeWriter.cs (1)
56/// <summary>Makes bytes written available to <see cref="System.IO.Pipelines.PipeReader" /> and runs <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> continuation.</summary>
System\IO\Pipelines\ReadResult.cs (6)
8/// <summary>Represents the result of a <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> call.</summary> 15/// <param name="buffer">The read-only sequence containing the bytes of data that were read in the <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> call.</param> 16/// <param name="isCanceled">A flag that indicates if the <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> operation that produced this <see cref="System.IO.Pipelines.ReadResult" /> was canceled by <see cref="System.IO.Pipelines.PipeReader.CancelPendingRead" />.</param> 34/// <value>A read-only sequence containing the bytes of data that were read in the <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> call.</value> 37/// <summary>Gets a value that indicates whether the current <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> operation was canceled by <see cref="System.IO.Pipelines.PipeReader.CancelPendingRead" />.</summary> 38/// <value><see langword="true" /> if the <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> operation that produced this <see cref="System.IO.Pipelines.ReadResult" /> was canceled by <see cref="System.IO.Pipelines.PipeReader.CancelPendingRead" />; otherwise, <see langword="false" />.</value>