PurgeBuffersAsync()

async ValueTask System.IO.Compression.DeflateStream.PurgeBuffersAsync ( )

inlineprivate

Definition at line 701 of file DeflateStream.cs.

    {
        if (_stream == null || _mode != CompressionMode.Compress)
        {
            return;
        }
        if (_wroteBytes)
        {
            await WriteDeflaterOutputAsync(default(CancellationToken)).ConfigureAwait(continueOnCapturedContext: false);
            bool finished;
            do
            {
                finished = _deflater.Finish(_buffer, out var bytesRead);
                if (bytesRead > 0)
                {
                    await _stream.WriteAsync(new ReadOnlyMemory<byte>(_buffer, 0, bytesRead)).ConfigureAwait(continueOnCapturedContext: false);
                }
            }
            while (!finished);
        }
        else
        {
            int bytesRead2;
            while (!_deflater.Finish(_buffer, out bytesRead2))
            {
            }
        }
    }

References System.IO.Compression.DeflateStream._buffer, System.IO.Compression.DeflateStream._deflater, System.IO.Compression.DeflateStream._mode, System.IO.Compression.DeflateStream._stream, System.IO.Compression.DeflateStream._wroteBytes, System.Threading.Tasks.ValueTask< TResult >.ConfigureAwait(), System.IO.Compression.Deflater.Finish(), System.IO.Stream.WriteAsync(), and System.IO.Compression.DeflateStream.WriteDeflaterOutputAsync().

Referenced by System.IO.Compression.DeflateStream.DisposeAsync().