FlushAsyncInternal()

async Task System.IO.Strategies.BufferedFileStreamStrategy.FlushAsyncInternal ( CancellationToken cancellationToken )

inlineprivate

Definition at line 919 of file BufferedFileStreamStrategy.cs.

    {
        await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
        try
        {
            if (_writePos > 0)
            {
                await _strategy.WriteAsync(new ReadOnlyMemory<byte>(_buffer, 0, _writePos), cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
                _writePos = 0;
            }
            else if (_readPos < _readLen && _strategy.CanSeek)
            {
                FlushRead();
            }
        }
        finally
        {
            _asyncActiveSemaphore.Release();
        }
    }

References System.IO.Stream._asyncActiveSemaphore, System.IO.Strategies.BufferedFileStreamStrategy._buffer, System.IO.Strategies.BufferedFileStreamStrategy._readLen, System.IO.Strategies.BufferedFileStreamStrategy._readPos, System.IO.Strategies.BufferedFileStreamStrategy._strategy, System.IO.Strategies.BufferedFileStreamStrategy._writePos, System.cancellationToken, System.IO.Stream.CanSeek, System.Threading.Tasks.Task< TResult >.ConfigureAwait(), System.IO.Stream.EnsureAsyncActiveSemaphoreInitialized(), System.IO.Strategies.BufferedFileStreamStrategy.FlushRead(), System.Threading.SemaphoreSlim.Release(), System.Threading.SemaphoreSlim.WaitAsync(), and System.IO.Stream.WriteAsync().

Referenced by System.IO.Strategies.BufferedFileStreamStrategy.FlushAsync().