Skip to content

Commit bf15481

Browse files
authored
Fix typing error in futures::bufread
Also add back comments Signed-off-by: Jiahao XU <[email protected]>
1 parent 8bb9eca commit bf15481

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/futures/bufread/generic/decoder.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,8 +89,10 @@ impl<R: AsyncBufRead, D: Decode> Decoder<R, D> {
8989
this.reader.as_mut().consume(input.written().len());
9090
done
9191
}
92+
// ignore the first error, occurs when input is empty
93+
// but we need to run decode to flush
9294
Err(err) if first => false,
93-
Err(err) => return Err(err),
95+
Err(err) => return Poll::Ready(Err(err)),
9496
};
9597

9698
first = false;

0 commit comments

Comments
 (0)