20 references to ReadAtLeastAsync
dotnet (1)
Commands\Test\MTP\IPC\NamedPipeServer.cs (1)
91
? await _namedPipeServerStream.
ReadAtLeastAsync
(_readBuffer, minimumBytes: sizeof(int), throwOnEndOfStream: false, cancellationToken)
System.Formats.Tar (1)
src\runtime\src\libraries\Common\src\System\ReadWriteAdapter.cs (1)
38
stream.
ReadAtLeastAsync
(buffer, minimumBytes, throwOnEndOfStream, cancellationToken);
System.IO.Compression (12)
System\IO\Compression\ZipArchive.Async.cs (1)
228
int currBytesRead = await _archiveStream.
ReadAtLeastAsync
(fileBuffer, ZipCentralDirectoryFileHeader.BlockConstantSectionSize, throwOnEndOfStream: false, cancellationToken).ConfigureAwait(false);
System\IO\Compression\ZipArchiveEntry.Async.cs (2)
484
await _archive.ArchiveStream.
ReadAtLeastAsync
(_compressedBytes[i], maxSingleBufferSize, throwOnEndOfStream: true, cancellationToken).ConfigureAwait(false);
486
await _archive.ArchiveStream.
ReadAtLeastAsync
(_compressedBytes[_compressedBytes.Length - 1], (int)(_compressedSize % maxSingleBufferSize), throwOnEndOfStream: true, cancellationToken).ConfigureAwait(false);
System\IO\Compression\ZipBlocks.Async.cs (6)
84
int bytesRead = await stream.
ReadAtLeastAsync
(blockContents, blockContents.Length, throwOnEndOfStream: false, cancellationToken).ConfigureAwait(false);
109
int bytesRead = await stream.
ReadAtLeastAsync
(blockContents, blockContents.Length, throwOnEndOfStream: false, cancellationToken).ConfigureAwait(false);
171
int bytesRead = await stream.
ReadAtLeastAsync
(blockBytes, blockBytes.Length, throwOnEndOfStream: false, cancellationToken).ConfigureAwait(false);
176
bytesRead = await stream.
ReadAtLeastAsync
(blockBytes, blockBytes.Length, throwOnEndOfStream: false, cancellationToken).ConfigureAwait(false);
219
int realBytesRead = await furtherReads.
ReadAtLeastAsync
(collatedHeader.Slice(remainingBufferLength), bytesToRead, throwOnEndOfStream: false, cancellationToken).ConfigureAwait(false);
265
int bytesRead = await stream.
ReadAtLeastAsync
(blockContents, blockContents.Length, throwOnEndOfStream: false, cancellationToken).ConfigureAwait(false);
System\IO\Compression\ZipHelper.Async.cs (2)
101
bytesRead = await stream.
ReadAtLeastAsync
(buffer, buffer.Length, throwOnEndOfStream: true, cancellationToken).ConfigureAwait(false);
108
bytesRead = await stream.
ReadAtLeastAsync
(buffer, bytesToRead, throwOnEndOfStream: true, cancellationToken).ConfigureAwait(false);
System\IO\Compression\Zstandard\ZstandardStream.Decompress.cs (1)
233
? await _stream.
ReadAtLeastAsync
(_buffer.AvailableMemory.Slice(0, needed), needed, throwOnEndOfStream: false, cancellationToken: cancellationToken).ConfigureAwait(false)
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\SocksHelper.cs (1)
358
? await stream.
ReadAtLeastAsync
(buffer, buffer.Length, throwOnEndOfStream: false).ConfigureAwait(false)
System.Net.Mail (1)
src\runtime\src\libraries\Common\src\System\ReadWriteAdapter.cs (1)
38
stream.
ReadAtLeastAsync
(buffer, minimumBytes, throwOnEndOfStream, cancellationToken);
System.Net.Security (1)
src\runtime\src\libraries\Common\src\System\ReadWriteAdapter.cs (1)
38
stream.
ReadAtLeastAsync
(buffer, minimumBytes, throwOnEndOfStream, cancellationToken);
System.Net.WebSockets (2)
System\Net\WebSockets\ManagedWebSocket.cs (2)
939
int numBytesRead = await _stream.
ReadAtLeastAsync
(
1618
int numRead = await _stream.
ReadAtLeastAsync
(
System.Private.Xml (1)
System\Xml\Core\XmlTextReaderImplAsync.cs (1)
914
int read = await stream.
ReadAtLeastAsync
(_ps.bytes.AsMemory(_ps.bytesUsed), bytesToRead, throwOnEndOfStream: false).ConfigureAwait(false);