1 write to _buffer
System.IO.Compression (1)
System\IO\Compression\Zstandard\ZstandardStream.cs (1)
54
_buffer
= new ArrayBuffer(DefaultInternalBufferSize, usePool: true);
18 references to _buffer
System.IO.Compression (18)
System\IO\Compression\Zstandard\ZstandardStream.Compress.cs (2)
114
Span<byte> output =
_buffer
.AvailableSpan;
175
Memory<byte> output =
_buffer
.AvailableMemory;
System\IO\Compression\Zstandard\ZstandardStream.cs (2)
28
[MemberNotNull(nameof(
_buffer
))]
229
_buffer
.Dispose();
System\IO\Compression\Zstandard\ZstandardStream.Decompress.cs (14)
40
lastResult = _decoder.Decompress(
_buffer
.ActiveSpan, destination, out int bytesConsumed, out bytesWritten);
41
_buffer
.Discard(bytesConsumed);
65
if (
_buffer
.ActiveLength != 0)
74
(lastResult == OperationStatus.DestinationTooSmall && destination.IsEmpty &&
_buffer
.ActiveLength == 0), $"{nameof(lastResult)} == {lastResult}, {nameof(destination.Length)} == {destination.Length}");
120
_buffer
.EnsureAvailableSpace(1);
122
int bytesRead = _stream.Read(
_buffer
.AvailableSpan);
132
if (bytesRead >
_buffer
.AvailableLength)
137
_buffer
.Commit(bytesRead);
197
_buffer
.EnsureAvailableSpace(1);
199
int bytesRead = await _stream.ReadAsync(
_buffer
.AvailableMemory, cancellationToken).ConfigureAwait(false);
209
if (bytesRead >
_buffer
.AvailableLength)
214
_buffer
.Commit(bytesRead);
282
int unconsumedBytes =
_buffer
.ActiveLength;
287
_buffer
.Discard(unconsumedBytes);