We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fcfd443 commit f9894d2Copy full SHA for f9894d2
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