We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b8a6c54 commit e5dd0d5Copy full SHA for e5dd0d5
crates/compression-codecs/src/zstd/decoder.rs
@@ -61,7 +61,12 @@ impl Decode for ZstdDecoder {
61
.run_on_buffers(input.unwritten(), output.unwritten_mut())?;
62
input.advance(status.bytes_read);
63
output.advance(status.bytes_written);
64
- Ok(status.remaining == 0)
+
65
+ // See docs on remaining field
66
+ let finished_frame = status.remaining == 0;
67
+ // ... && "no more data"
68
+ let done = finished_frame && status.bytes_read == 0;
69
+ Ok(done)
70
}
71
72
fn flush(
0 commit comments