2 writes to _stream
System.IO.Compression (2)
System\IO\Compression\Zstandard\ZstandardStream.cs (2)
53_stream = stream; 213_stream = null!;
19 references to _stream
System.IO.Compression (19)
System\IO\Compression\Zstandard\ZstandardStream.Compress.cs (4)
139_stream.Write(output.Slice(0, bytesWritten)); 200await _stream.WriteAsync(output.Slice(0, bytesWritten), cancellationToken).ConfigureAwait(false); 326_stream.Flush(); 351await _stream.FlushAsync(cancellationToken).ConfigureAwait(false);
System\IO\Compression\Zstandard\ZstandardStream.cs (9)
27[MemberNotNull(nameof(_stream))] 119return _stream; 125public override bool CanRead => _mode == CompressionMode.Decompress && _stream?.CanRead == true; 129public override bool CanWrite => _mode == CompressionMode.Compress && _stream?.CanWrite == true; 165if (disposing && _stream != null) 174_stream.Dispose(); 191if (_stream != null) 200await _stream.DisposeAsync().ConfigureAwait(false); 235ObjectDisposedException.ThrowIf(_stream == null, this);
System\IO\Compression\Zstandard\ZstandardStream.Decompress.cs (6)
164int bytesRead = _stream.Read(_buffer.AvailableSpan); 233? await _stream.ReadAtLeastAsync(_buffer.AvailableMemory.Slice(0, needed), needed, throwOnEndOfStream: false, cancellationToken: cancellationToken).ConfigureAwait(false) 234: _stream.ReadAtLeast(_buffer.AvailableSpan.Slice(0, needed), needed, throwOnEndOfStream: false); 275if (_stream.CanSeek) 277TryRewindStream(_stream); 338int bytesRead = await _stream.ReadAsync(_buffer.AvailableMemory, cancellationToken).ConfigureAwait(false);