ReadFromUnderlyingStreamAsync()

async ValueTask< int > System.IO.BufferedStream.ReadFromUnderlyingStreamAsync ( Memory< byte > buffer, CancellationToken cancellationToken, int bytesAlreadySatisfied, Task semaphoreLockTask )

inlineprivate

Definition at line 502 of file BufferedStream.cs.

    {
        await semaphoreLockTask.ConfigureAwait(continueOnCapturedContext: false);
        try
        {
            int num = ReadFromBuffer(buffer.Span);
            if (num == buffer.Length)
            {
                return bytesAlreadySatisfied + num;
            }
            if (num > 0)
            {
                buffer = buffer.Slice(num);
                bytesAlreadySatisfied += num;
            }
            _readPos = (_readLen = 0);
            if (_writePos > 0)
            {
                await FlushWriteAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
            }
            if (buffer.Length >= _bufferSize)
            {
                return await _stream.ReadAsync(buffer, cancellationToken).ConfigureAwait(continueOnCapturedContext: false) + bytesAlreadySatisfied;
            }
            EnsureBufferAllocated();
            _readLen = await _stream.ReadAsync(new Memory<byte>(_buffer, 0, _bufferSize), cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
            num = ReadFromBuffer(buffer.Span);
            return bytesAlreadySatisfied + num;
        }
        finally
        {
            _asyncActiveSemaphore.Release();
        }
    }

References System.IO.Stream._asyncActiveSemaphore, System.IO.BufferedStream._buffer, System.IO.BufferedStream._bufferSize, System.IO.BufferedStream._readLen, System.IO.BufferedStream._readPos, System.IO.BufferedStream._stream, System.IO.BufferedStream._writePos, System.buffer, System.cancellationToken, System.Threading.Tasks.Task< TResult >.ConfigureAwait(), System.Threading.Tasks.ValueTask< TResult >.ConfigureAwait(), System.IO.BufferedStream.EnsureBufferAllocated(), System.IO.BufferedStream.FlushWriteAsync(), System.IO.Stream.ReadAsync(), System.IO.BufferedStream.ReadFromBuffer(), and System.Threading.SemaphoreSlim.Release().

Referenced by System.IO.BufferedStream.ReadAsync(), and System.IO.BufferedStream.ReadAsync().