◆ ReadAsync() [3/3]

override ValueTask< int > System.IO.Compression.BrotliStream.ReadAsync	(	Memory< byte >	buffer,
		CancellationToken	cancellationToken = default(CancellationToken) )

inlinevirtual

Reimplemented from System.IO.Stream.

Definition at line 322 of file BrotliStream.cs.

    {
        if (_mode != 0)
        {
            throw new InvalidOperationException(System.SR.BrotliStream_Compress_UnsupportedOperation);
        }
        EnsureNoActiveAsyncOperation();
        EnsureNotDisposed();
        if (cancellationToken.IsCancellationRequested)
        {
            return ValueTask.FromCanceled<int>(cancellationToken);
        }
        return Core(buffer, cancellationToken);
        async ValueTask<int> Core(Memory<byte> buffer, CancellationToken cancellationToken)
        {
            AsyncOperationStarting();
            try
            {
                int bytesWritten;
                while (!TryDecompress(buffer.Span, out bytesWritten))
                {
                    int num = await _stream.ReadAsync(_buffer.AsMemory(_bufferCount), cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
                    if (num <= 0)
                    {
                        break;
                    }
                    _bufferCount += num;
                    if (_bufferCount > _buffer.Length)
                    {
                        ThrowInvalidStream();
                    }
                }
                return bytesWritten;
            }
            finally
            {
                AsyncOperationCompleting();
            }
        }
    }