Base:
20 references to ReadAsync
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
Internal\QuicStreamContext.cs (1)
214
var bytesReceived = await _stream.
ReadAsync
(buffer);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (5)
QuicConnectionContextTests.cs (3)
265
while ((readCount = await clientStream.
ReadAsync
(buffer).DefaultTimeout()) != -1)
279
readCount = await clientStream.
ReadAsync
(buffer).DefaultTimeout();
487
var clientEx = await Assert.ThrowsAsync<QuicException>(() => clientStream.
ReadAsync
(buffer).AsTask()).DefaultTimeout();
QuicStreamContextTests.cs (2)
423
var readCount = await clientStream.
ReadAsync
(new byte[1024]).DefaultTimeout();
466
var ex = await Assert.ThrowsAsync<QuicException>(() => clientStream.
ReadAsync
(new byte[1024]).AsTask()).DefaultTimeout();
System.Net.Http (10)
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (6)
493
bytesRead = await stream.
ReadAsync
(buffer.AvailableMemory, CancellationToken.None).ConfigureAwait(false);
569
bytesRead = await stream.
ReadAsync
(buffer.AvailableMemory, CancellationToken.None).ConfigureAwait(false);
703
bytesRead = await stream.
ReadAsync
(buffer.AvailableMemory, CancellationToken.None).ConfigureAwait(false);
736
bytesRead = await stream.
ReadAsync
(buffer.AvailableMemory, CancellationToken.None).ConfigureAwait(false);
787
bytesRead = await stream.
ReadAsync
(buffer.AvailableMemory, CancellationToken.None).ConfigureAwait(false);
816
int bytesRead = await stream.
ReadAsync
(buffer.AvailableMemory, CancellationToken.None).ConfigureAwait(false);
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (4)
820
bytesRead = await _stream.
ReadAsync
(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
889
int bytesRead = await _stream.
ReadAsync
(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
1088
int bytesRead = await _stream.
ReadAsync
(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
1225
int bytesRead = await _stream.
ReadAsync
(buffer.Slice(0, copyLen), cancellationToken).ConfigureAwait(false);
System.Net.Quic (4)
System\Net\Quic\QuicStream.cs (2)
135
/// Which might be by reading till end of stream (<see cref="
ReadAsync
(System.Memory{byte},System.Threading.CancellationToken)"/> will return <c>0</c>),
693
/// If the read side is not fully consumed, i.e.: <see cref="ReadsClosed"/> is not completed and/or <see cref="
ReadAsync
(Memory{byte}, CancellationToken)"/> hasn't returned <c>0</c>,
System\Net\Quic\QuicStream.Stream.cs (2)
126
int readLength =
ReadAsync
(new Memory<byte>(rentedBuffer, 0, buffer.Length), cts?.Token ?? default).AsTask().GetAwaiter().GetResult();
146
return
ReadAsync
(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();