2 writes to _stream
System.IO.Compression (2)
System\IO\Compression\Zstandard\ZstandardStream.cs (2)
52_stream = stream; 228_stream = null!;
19 references to _stream
System.IO.Compression (19)
System\IO\Compression\Zstandard\ZstandardStream.Compress.cs (4)
159_stream.Write(output.Slice(0, bytesWritten)); 220await _stream.WriteAsync(output.Slice(0, bytesWritten), cancellationToken).ConfigureAwait(false); 346_stream.Flush(); 371await _stream.FlushAsync(cancellationToken).ConfigureAwait(false);
System\IO\Compression\Zstandard\ZstandardStream.cs (9)
26[MemberNotNull(nameof(_stream))] 134return _stream; 140public override bool CanRead => _mode == CompressionMode.Decompress && _stream?.CanRead == true; 144public override bool CanWrite => _mode == CompressionMode.Compress && _stream?.CanWrite == true; 180if (disposing && _stream != null) 189_stream.Dispose(); 206if (_stream != null) 215await _stream.DisposeAsync().ConfigureAwait(false); 250ObjectDisposedException.ThrowIf(_stream == null, this);
System\IO\Compression\Zstandard\ZstandardStream.Decompress.cs (6)
172int bytesRead = _stream.Read(_buffer.AvailableSpan); 241? await _stream.ReadAtLeastAsync(_buffer.AvailableMemory.Slice(0, needed), needed, throwOnEndOfStream: false, cancellationToken: cancellationToken).ConfigureAwait(false) 242: _stream.ReadAtLeast(_buffer.AvailableSpan.Slice(0, needed), needed, throwOnEndOfStream: false); 283if (_stream.CanSeek) 285TryRewindStream(_stream); 346int bytesRead = await _stream.ReadAsync(_buffer.AvailableMemory, cancellationToken).ConfigureAwait(false);