We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 76e8004 + 6fdd0b3 commit 546e397Copy full SHA for 546e397
1 file changed
vortex-layout/src/layouts/buffered.rs
@@ -71,9 +71,7 @@ impl LayoutStrategy for BufferedStrategy {
71
if stream.as_mut().peek().await.is_none() {
72
let mut sequence_ptr = sequence_id.descend();
73
while let Some(chunk) = chunks.pop_front() {
74
- let chunk_size = chunk.nbytes();
75
- nbytes -= chunk_size;
76
- buffered_bytes_counter.fetch_sub(chunk_size, Ordering::Relaxed);
+ buffered_bytes_counter.fetch_sub(chunk.nbytes(), Ordering::Relaxed);
77
yield (sequence_ptr.advance(), chunk)
78
}
79
break;
0 commit comments