WriteAsync() [3/3]

override ValueTask System.IO.BufferedStream.WriteAsync ( ReadOnlyMemory< byte > buffer, CancellationToken cancellationToken = default(CancellationToken) )

inlinevirtual

Reimplemented from System.IO.Stream.

Definition at line 687 of file BufferedStream.cs.

    {
        if (cancellationToken.IsCancellationRequested)
        {
            return ValueTask.FromCanceled(cancellationToken);
        }
        EnsureNotClosed();
        EnsureCanWrite();
        SemaphoreSlim semaphoreSlim = EnsureAsyncActiveSemaphoreInitialized();
        Task task = semaphoreSlim.WaitAsync(cancellationToken);
        if (task.IsCompletedSuccessfully)
        {
            bool flag = true;
            try
            {
                if (_writePos == 0)
                {
                    ClearReadBufferBeforeWrite();
                }
                flag = buffer.Length < _bufferSize - _writePos;
                if (flag)
                {
                    int num = WriteToBuffer(buffer.Span);
                    return default(ValueTask);
                }
            }
            finally
            {
                if (flag)
                {
                    semaphoreSlim.Release();
                }
            }
        }
        return WriteToUnderlyingStreamAsync(buffer, cancellationToken, task);
    }

References System.IO.BufferedStream._bufferSize, System.IO.BufferedStream._writePos, System.buffer, System.cancellationToken, System.IO.BufferedStream.ClearReadBufferBeforeWrite(), System.IO.Stream.EnsureAsyncActiveSemaphoreInitialized(), System.IO.BufferedStream.EnsureCanWrite(), System.IO.BufferedStream.EnsureNotClosed(), System.Threading.Tasks.ValueTask< TResult >.FromCanceled(), System.Threading.SemaphoreSlim.Release(), System.task, System.Threading.SemaphoreSlim.WaitAsync(), System.IO.BufferedStream.WriteToBuffer(), and System.IO.BufferedStream.WriteToUnderlyingStreamAsync().