FlushAsyncInternal()

async Task System.IO.BufferedStream.FlushAsyncInternal ( CancellationToken cancellationToken )

inlineprivate

Definition at line 255 of file BufferedStream.cs.

    {
        await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
        try
        {
            if (_writePos > 0)
            {
                await FlushWriteAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
            }
            else if (_readPos < _readLen)
            {
                if (_stream.CanSeek)
                {
                    FlushRead();
                }
                if (_stream.CanWrite)
                {
                    await _stream.FlushAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
                }
            }
            else if (_stream.CanWrite)
            {
                await _stream.FlushAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
            }
        }
        finally
        {
            _asyncActiveSemaphore.Release();
        }
    }

References System.IO.Stream._asyncActiveSemaphore, System.IO.BufferedStream._readLen, System.IO.BufferedStream._readPos, System.IO.BufferedStream._stream, System.IO.BufferedStream._writePos, System.cancellationToken, System.IO.Stream.CanSeek, System.IO.Stream.CanWrite, System.Threading.Tasks.Task< TResult >.ConfigureAwait(), System.Threading.Tasks.ValueTask< TResult >.ConfigureAwait(), System.IO.Stream.EnsureAsyncActiveSemaphoreInitialized(), System.IO.Stream.FlushAsync(), System.IO.BufferedStream.FlushRead(), System.IO.BufferedStream.FlushWriteAsync(), System.Threading.SemaphoreSlim.Release(), and System.Threading.SemaphoreSlim.WaitAsync().

Referenced by System.IO.BufferedStream.FlushAsync().