ReadAsync

BrowserLogsCdpConnectionTests.cs (1)

599public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

Dcp\GatedReadStream.cs (1)

57public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

Circuits\RemoteJSDataStream.cs (1)

188public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\aspnetcore\src\Components\Shared\src\ArrayBuilderMemoryStream.cs (1)

56public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

Forms\InputFile\BrowserFileStream.cs (1)

70public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\aspnetcore\src\Components\Shared\src\ArrayBuilderMemoryStream.cs (1)

56public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

src\aspnetcore\src\Components\Shared\src\PullFromJSDataStream.cs (1)

79public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\aspnetcore\src\Components\Shared\src\ArrayBuilderMemoryStream.cs (1)

56public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

src\aspnetcore\src\Components\Shared\src\PullFromJSDataStream.cs (1)

79public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

Internal\ReferenceReadStream.cs (1)

104public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

BufferingStream.cs (1)

293public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

Infrastructure\NonDisposableStream.cs (1)

82public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

src\aspnetcore\src\Shared\SizeLimitedStream.cs (1)

87public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

RequestProcessing\OpaqueStream.cs (1)

103public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

Core\DuplexStream.cs (1)

58public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

Core\HttpRequestStream.cs (1)

51public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)

Core\HttpUpgradeStream.cs (1)

143public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)

Core\WrappingStream.cs (1)

63public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)

Core\WriteOnlyStreamInternal.cs (1)

49public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

86public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)

Internal\Http\HttpRequestStream.cs (1)

42public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)

Internal\Http\HttpResponseStream.cs (1)

46public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

Internal\Http\HttpUpgradeStream.cs (1)

143public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)

Internal\Infrastructure\WrappingStream.cs (1)

62public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)

Internal\Infrastructure\WriteOnlyStream.cs (1)

24public override ValueTask<int> ReadAsync(Memory<byte> memory, CancellationToken cancellationToken)

Middleware\Internal\LoggingStream.cs (1)

106public override async ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

86public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)

AsyncStreamWrapper.cs (1)

57public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

ResponseBodyReaderStream.cs (1)

77public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\sdk\src\Dotnet.Watch\Web.Middleware\ResponseStreamWrapper.cs (1)

154public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\sdk\src\Dotnet.Watch\Web.Middleware\ScriptInjectingStream.cs (1)

306public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

AbortStream.cs (1)

55public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

BufferedReadStream.cs (1)

226public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

FileBufferingReadStream.cs (1)

334public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

FileBufferingWriteStream.cs (1)

103public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

MultipartReaderStream.cs (1)

250public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

Logging\BinaryLogger\Postprocessing\SubStream.cs (1)

93public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

Logging\BinaryLogger\Postprocessing\TransparentReadStream.cs (1)

143public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

OpenAIFileDownloadStream.cs (1)

120public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) =>

NotSeekableStream.cs (1)

34public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) => _innerStream.ReadAsync(buffer, cancellationToken);

Logging\Internal\NotSeekableStream.cs (1)

34public override ValueTask<int> ReadAsync(System.Memory<byte> buffer, CancellationToken cancellationToken = default) => _innerStream.ReadAsync(buffer, cancellationToken);

src\runtime\src\libraries\Common\src\System\IO\SubReadStream.cs (1)

215public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Formats\Tar\GnuSparseStream.cs (1)

199public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\runtime\src\libraries\Common\src\System\IO\SubReadStream.cs (1)

215public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\DeflateManaged\DeflateManagedStream.cs (1)

260public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\DeflateZLib\DeflateStream.cs (1)

429public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\GZipStream.cs (1)

217public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default(CancellationToken))

System\IO\Compression\PositionPreservingWriteOnlyStreamWrapper.cs (1)

117public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) => throw new NotSupportedException(SR.NotSupported);

System\IO\Compression\WinZipAesStream.cs (1)

438public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\ZipArchiveEntry.cs (1)

2293public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\ZipCryptoStream.cs (1)

394public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\ZipCustomStreams.cs (3)

129public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 347public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 600public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\ZLibStream.cs (1)

169public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\Zstandard\ZstandardStream.Decompress.cs (1)

310public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\dec\BrotliStream.Decompress.cs (1)

142public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default(CancellationToken))

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

99public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Pipes\PipeStream.Unix.cs (1)

82public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default(CancellationToken))

System\IO\Ports\SerialStream.Unix.cs (1)

462public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Buffers\ReadOnlySequenceStream.cs (1)

118public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\runtime\src\libraries\Common\src\System\IO\DelegatingStream.cs (1)

110public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\Http\HttpBaseStream.cs (1)

88public abstract override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken);

System\Net\Http\MultipartContent.cs (1)

516public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) =>

System\Net\Http\Json\LengthLimitReadStream.cs (1)

44public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\DelegatedStream.cs (1)

121public sealed override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\Quic\QuicStream.cs (1)

303public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\HttpWebResponse.cs (1)

413public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\NetworkStreamWrapper.cs (1)

193public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\Security\NegotiateStream.cs (1)

324public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\Security\SslStream.cs (1)

898public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\Sockets\NetworkStream.cs (1)

586public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\runtime\src\libraries\Common\src\System\IO\DelegatingStream.cs (1)

110public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\WebSockets\WebSocketStream.cs (1)

133public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) =>

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\BufferedStream.cs (1)

628public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\FileStream.cs (1)

294public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\MemoryStream.cs (1)

388public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\ReadOnlyMemoryStream.cs (1)

142public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\BufferedFileStreamStrategy.cs (1)

292public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\DerivedFileStreamStrategy.cs (1)

91public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\OSFileStreamStrategy.cs (1)

271public sealed override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken)

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Stream.cs (1)

1057public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) =>

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\StringStream.cs (1)

263public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\UnmanagedMemoryStream.cs (1)

446public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\WritableMemoryStream.cs (1)

144public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\runtime\src\libraries\System.Private.CoreLib\src\System\Text\TranscodingStream.cs (1)

367public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

System\Security\Cryptography\CryptoStream.cs (1)

224public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\ServiceModel\Channels\Connection.cs (1)

235public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\ServiceModel\Channels\DelegatingStream.cs (1)

92public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) => BaseStream.ReadAsync(buffer, cancellationToken);

Acquisition\PeerInstallProbe.cs (1)

359read = await stream.ReadAsync(buffer.AsMemory(), cancellationToken).ConfigureAwait(false);

ServiceClient\DashboardClient.cs (1)

1056while ((bytesRead = await fileStream.ReadAsync(buffer, combinedTokens.Token).ConfigureAwait(false)) > 0)

Terminal\TerminalWebSocketProxy.cs (1)

346var read = await upstream.ReadAsync(buffer.AsMemory(0, OutboundBufferSize), token).ConfigureAwait(false);

BrowserLogsCdpConnection.cs (1)

543_readBufferCount = await _readStream.ReadAsync(_readBuffer, cancellationToken).ConfigureAwait(false);

BrowserHostTests.cs (1)

128var read = await _browserRead.ReadAsync(oneByte);

BrowserLogsCdpConnectionTests.cs (1)

378var read = await stream.ReadAsync(oneByte);

BrowserLogsPipeBrowserProcessLauncherTests.cs (1)

82var read = await stream.ReadAsync(buffer.AsMemory(offset, buffer.Length - offset));

src\Aspire.Hosting.Browsers\BrowserLogsCdpConnection.cs (1)

543_readBufferCount = await _readStream.ReadAsync(_readBuffer, cancellationToken).ConfigureAwait(false);

DcpUpstreamAdapter.cs (1)

446var n = await stream.ReadAsync(buffer.AsMemory(read), ct).ConfigureAwait(false);

Commands\Test\MTP\IPC\HttpTestHostGateway.cs (1)

303while ((bytesRead = await request.InputStream.ReadAsync(bytes, cancellationToken)) != 0)

src\roslyn\src\Compilers\Core\Portable\Hashing\NonCryptographicHashAlgorithm.cs (1)

165int read = await stream.ReadAsync(buffer.AsMemory(), cancellationToken).ConfigureAwait(false);

Circuits\CircuitHost.cs (1)

518return await Renderer.Dispatcher.InvokeAsync(async () => await dotNetStreamReference.Stream.ReadAsync(buffer));

Circuits\RemoteJSDataStream.cs (2)

185return await _pipeReaderStream.ReadAsync(buffer.AsMemory(offset, count), linkedCts.Token); 191return await _pipeReaderStream.ReadAsync(buffer, linkedCts.Token);

Forms\InputFile\BrowserFileStream.cs (1)

105return await stream.ReadAsync(destination, _copyFileDataCts.Token);

src\aspnetcore\src\Components\Shared\src\TransmitDataStreamToJS.cs (1)

22while ((bytesRead = await dotNetStreamReference.Stream.ReadAsync(buffer)) > 0)

src\aspnetcore\src\Components\Shared\src\TransmitDataStreamToJS.cs (1)

22while ((bytesRead = await dotNetStreamReference.Stream.ReadAsync(buffer)) > 0)

Internal\ReferenceReadStream.cs (1)

109var read = await _inner.ReadAsync(buffer.Slice(0, toRead), cancellationToken);

src\aspnetcore\src\Http\Shared\StreamCopyOperationInternal.cs (1)

59var read = await source.ReadAsync(buffer.AsMemory(0, readLength), cancel);

src\aspnetcore\src\Http\Shared\StreamCopyOperationInternal.cs (1)

59var read = await source.ReadAsync(buffer.AsMemory(0, readLength), cancel);

src\aspnetcore\src\Http\Shared\StreamCopyOperationInternal.cs (1)

59var read = await source.ReadAsync(buffer.AsMemory(0, readLength), cancel);

BufferingStream.cs (1)

295return _innerStream.ReadAsync(buffer, cancellationToken);

RequestBufferingStream.cs (2)

32var res = await _innerStream.ReadAsync(destination, cancellationToken); 47var res = await _innerStream.ReadAsync(buffer.AsMemory(offset, count), cancellationToken);

Infrastructure\NonDisposableStream.cs (1)

84return _innerStream.ReadAsync(buffer, cancellationToken);

Utilities\Hashing\NonCryptographicHashAlgorithm.cs (1)

164int read = await stream.ReadAsync(buffer.AsMemory(), cancellationToken).ConfigureAwait(false);

src\aspnetcore\src\Shared\SizeLimitedStream.cs (1)

89var bytesRead = await _innerStream.ReadAsync(buffer, cancellationToken);

RequestProcessing\OpaqueStream.cs (1)

105return _requestStream.ReadAsync(buffer, cancellationToken);

Core\DuplexStream.cs (1)

60return _requestBody.ReadAsync(buffer, cancellationToken);

Core\HttpUpgradeStream.cs (1)

145return _requestStream.ReadAsync(destination, cancellationToken);

Core\WrappingStream.cs (1)

64=> _inner.ReadAsync(destination, cancellationToken);

Internal\Http\HttpUpgradeStream.cs (1)

145return _requestStream.ReadAsync(destination, cancellationToken);

Internal\Infrastructure\WrappingStream.cs (1)

63=> _inner.ReadAsync(destination, cancellationToken);

Middleware\Internal\LoggingStream.cs (2)

98int read = await _inner.ReadAsync(buffer.AsMemory(offset, count), cancellationToken); 108int read = await _inner.ReadAsync(destination, cancellationToken);

AsyncStreamWrapper.cs (1)

59return _inner.ReadAsync(buffer, cancellationToken);

AbortStream.cs (1)

57return _innerStream.ReadAsync(buffer, cancellationToken);

BufferedReadStream.cs (3)

238return await _inner.ReadAsync(buffer, cancellationToken); 270_bufferCount = await _inner.ReadAsync(_buffer.AsMemory(), cancellationToken); 329int read = await _inner.ReadAsync(_buffer.AsMemory(_bufferOffset + _bufferCount, _buffer.Length - _bufferCount - _bufferOffset), cancellationToken);

FileBufferingReadStream.cs (2)

341return await _buffer.ReadAsync(buffer, cancellationToken); 344var read = await _inner.ReadAsync(buffer, cancellationToken);

HttpRequestStreamReader.cs (2)

259_bytesRead = await _stream.ReadAsync(_byteBuffer.AsMemory(0, _byteBufferSize), cancellationToken); 490_bytesRead = await _stream.ReadAsync(_byteBuffer.AsMemory(0, _byteBufferSize)).ConfigureAwait(false);

StreamHelperExtensions.cs (2)

62var read = await stream.ReadAsync(buffer.AsMemory(), cancellationToken); 72read = await stream.ReadAsync(buffer.AsMemory(), cancellationToken);

BackEnd\Client\MSBuildClientPacketPump.cs (3)

209Task<int> readTask = localStream.ReadAsync(headerByte.AsMemory(), CancellationToken.None).AsTask(); 281ValueTask<int> bytesReadTask = localStream.ReadAsync(packetData.AsMemory(packetBytesRead, packetLength - packetBytesRead)); 312readTask = localStream.ReadAsync(headerByte.AsMemory(), CancellationToken.None).AsTask();

BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (2)

1120int bytesRead = await _readStream.ReadAsync(_headerByte.AsMemory(), CancellationToken.None).ConfigureAwait(false); 1145int bytesRead = await _readStream.ReadAsync(packetData.AsMemory(totalBytesRead, packetLength - totalBytesRead), CancellationToken.None).ConfigureAwait(false);

Logging\BinaryLogger\Postprocessing\SubStream.cs (2)

73int read = await _stream.ReadAsync( 96int read = await _stream.ReadAsync(buffer, cancellationToken).ConfigureAwait(false);

Logging\BinaryLogger\Postprocessing\TransparentReadStream.cs (2)

119int cnt = await _stream.ReadAsync( 150int cnt = await _stream.ReadAsync(buffer, cancellationToken).ConfigureAwait(false);

src\msbuild\src\Shared\NodeEndpointOutOfProcBase.cs (2)

684Task<int> readTask = localReadPipe.ReadAsync(headerByte.AsMemory(), CancellationToken.None).AsTask(); 857readTask = localReadPipe.ReadAsync(headerByte.AsMemory(), CancellationToken.None).AsTask();

Hashing\NonCryptographicHashAlgorithm.cs (1)

165int read = await stream.ReadAsync(buffer.AsMemory(), cancellationToken).ConfigureAwait(false);

src\roslyn\src\Compilers\Core\Portable\Hashing\NonCryptographicHashAlgorithm.cs (1)

165int read = await stream.ReadAsync(buffer.AsMemory(), cancellationToken).ConfigureAwait(false);

UI\PhysicalConsole.cs (1)

37var bytesRead = await stream.ReadAsync(buffer, CancellationToken.None);

OpenAIFileDownloadStream.cs (1)

121_innerStream.ReadAsync(buffer, cancellationToken);

Logging\HttpRequestBodyReaderTest.cs (1)

178streamMock.Setup(x => x.ReadAsync(It.IsAny<Memory<byte>>(), It.IsAny<CancellationToken>())).Throws<OperationCanceledException>();

Logging\HttpResponseBodyReaderTest.cs (2)

216streamMock.Setup(x => x.ReadAsync(It.IsAny<Memory<byte>>(), It.IsAny<CancellationToken>())).Throws<OperationCanceledException>(); 245streamMock.Setup(x => x.ReadAsync(It.IsAny<Memory<byte>>(), It.IsAny<CancellationToken>())).Throws(exception);

Registry\Registry.cs (1)

513int bytesRead = await contents.ReadAsync(chunkBackingStore, cancellationToken).ConfigureAwait(false);

src\msbuild\src\Shared\NodeEndpointOutOfProcBase.cs (2)

684Task<int> readTask = localReadPipe.ReadAsync(headerByte.AsMemory(), CancellationToken.None).AsTask(); 857readTask = localReadPipe.ReadAsync(headerByte.AsMemory(), CancellationToken.None).AsTask();

ServerSentEvents\SseParser_1.cs (1)

523_stream.ReadAsync(_lineBuffer.AsMemory(offset), cancellationToken)

System\Diagnostics\AsyncStreamReader.cs (1)

97int bytesRead = await _stream.ReadAsync(new Memory<byte>(_byteBuffer), _cts.Token).ConfigureAwait(false);

System\Diagnostics\Process.Multiplexing.cs (1)

489while ((read = await stream.ReadAsync(buffer.AsMemory(bytesRead), cancellationToken).ConfigureAwait(false)) > 0)

src\runtime\src\libraries\Common\src\System\IO\SubReadStream.cs (1)

236int ret = await _superStream.ReadAsync(buffer, cancellationToken).ConfigureAwait(false);

src\runtime\src\libraries\Common\src\System\ReadWriteAdapter.cs (1)

35stream.ReadAsync(buffer, cancellationToken);

src\runtime\src\libraries\Common\src\System\IO\SubReadStream.cs (1)

236int ret = await _superStream.ReadAsync(buffer, cancellationToken).ConfigureAwait(false);

System\IO\Compression\DeflateManaged\DeflateManagedStream.cs (2)

188ValueTask<int> readTask = _stream!.ReadAsync(_buffer.AsMemory(), cancellationToken); 234readTask = _stream!.ReadAsync(_buffer.AsMemory(), cancellationToken);

System\IO\Compression\DeflateZLib\DeflateStream.cs (2)

435return base.ReadAsync(buffer, cancellationToken); 479int n = await _stream.ReadAsync(new Memory<byte>(_buffer, 0, _buffer.Length), cancellationToken).ConfigureAwait(false);

System\IO\Compression\GZipStream.cs (1)

224return base.ReadAsync(buffer, cancellationToken);

System\IO\Compression\WinZipAesStream.cs (1)

455int bytesRead = await _baseStream.ReadAsync(buffer.Slice(0, bytesToRead), cancellationToken).ConfigureAwait(false);

System\IO\Compression\ZipCryptoStream.cs (1)

403int n = await _base.ReadAsync(buffer, cancellationToken).ConfigureAwait(false);

System\IO\Compression\ZipCustomStreams.cs (2)

134return _baseStream.ReadAsync(buffer, cancellationToken); 604int bytesRead = await _baseStream.ReadAsync(buffer, cancellationToken).ConfigureAwait(false);

System\IO\Compression\Zstandard\ZstandardStream.Decompress.cs (1)

338int bytesRead = await _stream.ReadAsync(_buffer.AvailableMemory, cancellationToken).ConfigureAwait(false);

System\IO\Compression\dec\BrotliStream.Decompress.cs (1)

166int bytesRead = await _stream.ReadAsync(_buffer.AsMemory(_bufferCount), cancellationToken).ConfigureAwait(false);

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

128int read = await source.ReadAsync(buffer, cancellationToken).ConfigureAwait(false);

System\IO\Pipelines\StreamPipeReader.cs (2)

260await reader.InnerStream.ReadAsync(Memory<byte>.Empty, tokenSource.Token).ConfigureAwait(false); 269int length = await reader.InnerStream.ReadAsync(buffer, tokenSource.Token).ConfigureAwait(false);

src\runtime\src\libraries\Common\src\System\IO\DelegatingStream.cs (1)

112return _innerStream.ReadAsync(buffer, cancellationToken);

System\Net\Http\MultipartContent.cs (1)

536int bytesRead = await _current.ReadAsync(buffer, cancellationToken).ConfigureAwait(false);

System\Net\Http\SocketsHttpHandler\DecompressionHandler.cs (4)

301return await thisRef._decompressionStream.ReadAsync(buffer, cancellationToken).ConfigureAwait(false); 305return _decompressionStream.ReadAsync(buffer, cancellationToken); 372int bytesRead = await _stream.ReadAsync(buffer, cancellationToken).ConfigureAwait(false); 417return _stream.ReadAsync(buffer, cancellationToken);

System\Net\Http\SocketsHttpHandler\Http2Connection.cs (6)

426await _stream.ReadAsync(Memory<byte>.Empty).ConfigureAwait(false); 430int bytesRead = await _stream.ReadAsync(_incomingBuffer.AvailableMemory).ConfigureAwait(false); 473await _stream.ReadAsync(Memory<byte>.Empty).ConfigureAwait(false); 475int bytesRead = await _stream.ReadAsync(_incomingBuffer.AvailableMemory).ConfigureAwait(false); 547ValueTask<int> zeroByteReadTask = _stream.ReadAsync(Memory<byte>.Empty); 559int bytesRead = await _stream.ReadAsync(_incomingBuffer.AvailableMemory).ConfigureAwait(false);

System\Net\Http\SocketsHttpHandler\HttpConnection.cs (8)

170_readAheadTask = _stream.ReadAsync(_readBuffer.AvailableMemory); 256await _stream.ReadAsync(Memory<byte>.Empty).ConfigureAwait(false); 259int read = await _stream.ReadAsync(_readBuffer.AvailableMemory).ConfigureAwait(false); 1656await _stream.ReadAsync(_readBuffer.AvailableMemory).ConfigureAwait(false) : 1672await _stream.ReadAsync(_readBuffer.AvailableMemory).ConfigureAwait(false) : 1816: _stream.ReadAsync(destination); 1820int count = await _stream.ReadAsync(destination).ConfigureAwait(false); 1875int bytesRead = await _stream.ReadAsync(_readBuffer.AvailableMemory).ConfigureAwait(false);

System\Net\Http\Json\LengthLimitReadStream.cs (1)

46ValueTask<int> readTask = _innerStream.ReadAsync(buffer, cancellationToken);

src\runtime\src\libraries\Common\src\System\ReadWriteAdapter.cs (1)

35stream.ReadAsync(buffer, cancellationToken);

System\Net\Base64Stream.cs (1)

196int read = await BaseStream.ReadAsync(buffer, cancellationToken).ConfigureAwait(false);

System\Net\BufferedReadStream.cs (2)

55return BaseStream.ReadAsync(buffer, cancellationToken); 72int returnValue = await BaseStream.ReadAsync(buffer, cancellationToken).ConfigureAwait(false);

System\Net\CloseableStream.cs (1)

49return BaseStream.ReadAsync(buffer, cancellationToken);

System\Net\HttpWebResponse.cs (1)

415int readBytes = await innerStream.ReadAsync(buffer.Slice(0, (int)Math.Min(buffer.Length, _maxRemainingLength)), cancellationToken)

System\Net\NetworkStreamWrapper.cs (1)

195return Stream.ReadAsync(buffer, cancellationToken);

src\runtime\src\libraries\Common\src\System\ReadWriteAdapter.cs (1)

35stream.ReadAsync(buffer, cancellationToken);

System\Net\Security\NegotiateStream.cs (1)

329return InnerStream.ReadAsync(buffer, cancellationToken);

System\Net\ServerSentEvents\SseParser_1.cs (1)

526int bytesRead = await _stream.ReadAsync(_lineBuffer.AsMemory(offset), cancellationToken).ConfigureAwait(false);

src\runtime\src\libraries\Common\src\System\IO\DelegatingStream.cs (1)

112return _innerStream.ReadAsync(buffer, cancellationToken);

System\Net\WebClient.cs (1)

903int bytesRead = await readStream.ReadAsync(new Memory<byte>(copyBuffer)).ConfigureAwait(false);

System\Net\WebSockets\ManagedWebSocket.cs (2)

828await _stream.ReadAsync(Memory<byte>.Empty, cancellationToken).ConfigureAwait(false); 1154ValueTask<int> finalReadTask = _stream.ReadAsync(_receiveBuffer, cancellationToken);

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\BufferedStream.cs (2)

711return await _stream.ReadAsync(buffer, cancellationToken).ConfigureAwait(false) + bytesAlreadySatisfied; 716_readLen = await _stream.ReadAsync(new Memory<byte>(_buffer, 0, _bufferSize), cancellationToken).ConfigureAwait(false);

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\FileStream.cs (2)

310return _strategy.ReadAsync(buffer, cancellationToken); 608=> base.ReadAsync(buffer, cancellationToken);

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\BufferedFileStreamStrategy.cs (4)

325return _strategy.ReadAsync(buffer, cancellationToken); 381return await _strategy.ReadAsync(destination, cancellationToken).ConfigureAwait(false); 441return await _strategy.ReadAsync(buffer, cancellationToken).ConfigureAwait(false) + bytesAlreadySatisfied; 446_readLen = await _strategy.ReadAsync(new Memory<byte>(_buffer, 0, _bufferSize), cancellationToken).ConfigureAwait(false);

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Stream.cs (2)

106while ((bytesRead = await source.ReadAsync(new Memory<byte>(buffer), cancellationToken).ConfigureAwait(false)) != 0) 435int read = await ReadAsync(buffer.Slice(totalRead), cancellationToken).ConfigureAwait(false);

src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\StreamReader.cs (4)

1178int len = await tmpStream.ReadAsync(new Memory<byte>(tmpByteBuffer, tmpBytePos, tmpByteBuffer.Length - tmpBytePos), cancellationToken).ConfigureAwait(false); 1214_byteLen = await tmpStream.ReadAsync(new Memory<byte>(tmpByteBuffer), cancellationToken).ConfigureAwait(false); 1394int len = await tmpStream.ReadAsync(tmpByteBuffer.AsMemory(tmpBytePos), cancellationToken).ConfigureAwait(false); 1408_byteLen = await tmpStream.ReadAsync(new Memory<byte>(tmpByteBuffer), cancellationToken).ConfigureAwait(false);

src\runtime\src\libraries\System.Private.CoreLib\src\System\Text\TranscodingStream.cs (1)

404int innerBytesReadJustNow = await _innerStream.ReadAsync(rentedBytes.AsMemory(0, DefaultReadByteBufferSize), cancellationToken).ConfigureAwait(false);

System\Xml\Core\XmlTextReaderImplAsync.cs (1)

1127int read = await _ps.stream.ReadAsync(_ps.bytes.AsMemory(_ps.bytesUsed)).ConfigureAwait(false);

System\Security\Cryptography\CryptoStream.cs (2)

351await _stream.ReadAsync(new Memory<byte>(tempInputBuffer, _inputBufferIndex, numWholeBlocksInBytes - _inputBufferIndex), cancellationToken).ConfigureAwait(false) : 428await _stream.ReadAsync(new Memory<byte>(_inputBuffer, _inputBufferIndex, _inputBlockSize - _inputBufferIndex), cancellationToken).ConfigureAwait(false) :

System\Security\Cryptography\HashAlgorithm.cs (1)

138while ((bytesRead = await inputStream.ReadAsync(buffer, cancellationToken).ConfigureAwait(false)) > 0)

System\Security\Cryptography\LiteHashProvider.cs (1)

154while ((read = await source.ReadAsync(rented, cancellationToken).ConfigureAwait(false)) > 0)

System\Security\Cryptography\LiteHashProvider.Xof.cs (1)

139while ((read = await source.ReadAsync(rented, cancellationToken).ConfigureAwait(false)) > 0)

System\Security\Cryptography\Cose\CoseMessage.cs (1)

499while ((bytesRead = await content.ReadAsync(contentBuffer, cancellationToken).ConfigureAwait(false)) > 0)

System\ServiceModel\Channels\Connection.cs (1)

297return await Stream.ReadAsync(buffer);

System\ServiceModel\Channels\DelegatingStream.cs (1)

92public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) => BaseStream.ReadAsync(buffer, cancellationToken);

System\Text\Json\Document\JsonDocument.Parse.cs (2)

909lastRead = await stream.ReadAsync(rented.AsMemory(written, utf8BomLength - written), cancellationToken).ConfigureAwait(false); 932lastRead = await stream.ReadAsync(rented.AsMemory(written), cancellationToken).ConfigureAwait(false);

System\Text\Json\Serialization\StreamReadBufferState.cs (1)

74int bytesRead = await stream.ReadAsync(bufferState._buffer.AsMemory(bufferState._count), cancellationToken).ConfigureAwait(false);

System\Media\SoundPlayer.cs (2)

503int readBytes = await _stream.ReadAsync(_streamData.AsMemory(_currentPos, BlockSize), cancellationToken).ConfigureAwait(false); 515readBytes = await _stream.ReadAsync(_streamData.AsMemory(_currentPos, BlockSize), cancellationToken).ConfigureAwait(false);