ReadAsyncInternal()

ValueTask< int > System.IO.Compression.DeflateManagedStream.ReadAsyncInternal ( Memory< byte > buffer, CancellationToken cancellationToken )

inlineprivate

Definition at line 162 of file DeflateManagedStream.cs.

    {
        if (cancellationToken.IsCancellationRequested)
        {
            return ValueTask.FromCanceled<int>(cancellationToken);
        }
        Interlocked.Increment(ref _asyncOperations);
        bool flag = false;
        try
        {
            int num = _inflater.Inflate(buffer.Span);
            if (num != 0)
            {
                return ValueTask.FromResult(num);
            }
            if (_inflater.Finished())
            {
                return ValueTask.FromResult(0);
            }
            ValueTask<int> readTask = _stream.ReadAsync(_buffer.AsMemory(), cancellationToken);
            flag = true;
            return ReadAsyncCore(readTask, buffer, cancellationToken);
        }
        finally
        {
            if (!flag)
            {
                Interlocked.Decrement(ref _asyncOperations);
            }
        }
    }

References System.IO.Compression.DeflateManagedStream._asyncOperations, System.IO.Compression.DeflateManagedStream._buffer, System.IO.Compression.DeflateManagedStream._inflater, System.IO.Compression.DeflateManagedStream._stream, System.buffer, System.cancellationToken, System.Threading.Interlocked.Decrement(), System.IO.Compression.InflaterManaged.Finished(), System.Threading.Tasks.ValueTask< TResult >.FromCanceled(), System.Threading.Interlocked.Increment(), System.IO.Compression.InflaterManaged.Inflate(), System.IO.Stream.ReadAsync(), and System.IO.Compression.DeflateManagedStream.ReadAsyncCore().

Referenced by System.IO.Compression.DeflateManagedStream.ReadAsync(), and System.IO.Compression.DeflateManagedStream.ReadAsync().