Skip to content
Original file line number Diff line number Diff line change
Expand Up @@ -117,6 +117,8 @@ public override int Read(Span<byte> buffer)
OperationStatus lastResult;
while (!TryDecompress(buffer, out bytesWritten, out lastResult))
{
_buffer.EnsureAvailableSpace(1);

int bytesRead = _stream.Read(_buffer.AvailableSpan);
if (bytesRead <= 0)
{
Expand Down Expand Up @@ -192,6 +194,8 @@ public override async ValueTask<int> ReadAsync(Memory<byte> buffer, Cancellation
OperationStatus lastResult;
while (!TryDecompress(buffer.Span, out bytesWritten, out lastResult))
{
_buffer.EnsureAvailableSpace(1);

int bytesRead = await _stream.ReadAsync(_buffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
if (bytesRead <= 0)
{
Expand Down
Loading