Base:
21 references to ReadAsync
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
Internal\QuicStreamContext.cs (1)
214var bytesReceived = await _stream.ReadAsync(buffer);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (6)
QuicConnectionContextTests.cs (4)
265while ((readCount = await clientStream.ReadAsync(buffer).DefaultTimeout()) != -1) 279readCount = await clientStream.ReadAsync(buffer).DefaultTimeout(); 487var clientEx = await Assert.ThrowsAsync<QuicException>(() => clientStream.ReadAsync(buffer).AsTask()).DefaultTimeout(); 640var count = await clientStream.ReadAsync(new byte[1024]);
QuicStreamContextTests.cs (2)
423var readCount = await clientStream.ReadAsync(new byte[1024]).DefaultTimeout(); 466var ex = await Assert.ThrowsAsync<QuicException>(() => clientStream.ReadAsync(new byte[1024]).AsTask()).DefaultTimeout();
System.Net.Http (10)
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (6)
578bytesRead = await stream.ReadAsync(buffer.AvailableMemory, CancellationToken.None).ConfigureAwait(false); 654bytesRead = await stream.ReadAsync(buffer.AvailableMemory, CancellationToken.None).ConfigureAwait(false); 788bytesRead = await stream.ReadAsync(buffer.AvailableMemory, CancellationToken.None).ConfigureAwait(false); 821bytesRead = await stream.ReadAsync(buffer.AvailableMemory, CancellationToken.None).ConfigureAwait(false); 872bytesRead = await stream.ReadAsync(buffer.AvailableMemory, CancellationToken.None).ConfigureAwait(false); 901int bytesRead = await stream.ReadAsync(buffer.AvailableMemory, CancellationToken.None).ConfigureAwait(false);
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (4)
850bytesRead = await _stream.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false); 919int bytesRead = await _stream.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false); 1118int bytesRead = await _stream.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false); 1255int bytesRead = await _stream.ReadAsync(buffer.Slice(0, copyLen), cancellationToken).ConfigureAwait(false);
System.Net.Quic (4)
System\Net\Quic\QuicStream.cs (2)
142/// Which might be by reading till end of stream (<see cref="ReadAsync(System.Memory{byte},System.Threading.CancellationToken)"/> will return <c>0</c>), 707/// 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)
126int readLength = ReadAsync(new Memory<byte>(rentedBuffer, 0, buffer.Length), cts?.Token ?? default).AsTask().GetAwaiter().GetResult(); 146return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();