WriteAsyncMemory()

ValueTask System.IO.Compression.DeflateStream.WriteAsyncMemory ( ReadOnlyMemory< byte > buffer, CancellationToken cancellationToken )

inlinepackage

Definition at line 849 of file DeflateStream.cs.

    {
        EnsureCompressionMode();
        EnsureNoActiveAsyncOperation();
        EnsureNotDisposed();
        if (!cancellationToken.IsCancellationRequested)
        {
            return Core(buffer, cancellationToken);
        }
        return ValueTask.FromCanceled(cancellationToken);
        async ValueTask Core(ReadOnlyMemory<byte> buffer, CancellationToken cancellationToken)
        {
            AsyncOperationStarting();
            try
            {
                await WriteDeflaterOutputAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
                _deflater.SetInput(buffer);
                await WriteDeflaterOutputAsync(cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
                _wroteBytes = true;
            }
            finally
            {
                AsyncOperationCompleting();
            }
        }
    }

References System.IO.Compression.DeflateStream._deflater, System.IO.Compression.DeflateStream._wroteBytes, System.IO.Compression.DeflateStream.AsyncOperationCompleting(), System.IO.Compression.DeflateStream.AsyncOperationStarting(), System.buffer, System.cancellationToken, System.Threading.Tasks.ValueTask< TResult >.ConfigureAwait(), System.IO.Compression.DeflateStream.EnsureCompressionMode(), System.IO.Compression.DeflateStream.EnsureNoActiveAsyncOperation(), System.IO.Compression.DeflateStream.EnsureNotDisposed(), System.Threading.Tasks.ValueTask< TResult >.FromCanceled(), System.IO.Compression.Deflater.SetInput(), and System.IO.Compression.DeflateStream.WriteDeflaterOutputAsync().

Referenced by System.IO.Compression.DeflateStream.WriteAsync(), System.IO.Compression.DeflateStream.WriteAsync(), System.IO.Compression.GZipStream.WriteAsync(), and System.IO.Compression.ZLibStream.WriteAsync().