Skip to content

Commit a063a3e

Browse files
authored
Fix BufWriter::flush_buf: propagate error before reset (#438)
Fixed #435 Signed-off-by: Jiahao XU <30436523+NobodyXu@users.noreply.github.com>
1 parent 30a69f7 commit a063a3e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

crates/async-compression/src/generic/write/buf_writer.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -94,13 +94,13 @@ impl BufWriter {
9494
&mut self,
9595
poll_write: &mut dyn FnMut(&[u8]) -> Poll<io::Result<usize>>,
9696
) -> Poll<io::Result<()>> {
97-
let ret = ready!(self.do_flush(poll_write));
97+
ready!(self.do_flush(poll_write))?;
9898

9999
debug_assert_eq!(self.buffered, self.written);
100100
self.buffered = 0;
101101
self.written = 0;
102102

103-
Poll::Ready(ret)
103+
Poll::Ready(Ok(()))
104104
}
105105

106106
pub fn poll_write(

0 commit comments

Comments
 (0)