jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 19:09:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix sink implementation (#5594)

Browse Source
This commit is contained in:
Emilia Hane
2023-11-27 20:01:00 +01:00
committed by GitHub
parent 3d291ea292
commit 025511baa6
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
crates/net/eth-wire/src/p2pstream.rs
View File

@ -578,8 +578,7 @@ where
Ok(())
}
/// Returns Poll::Ready(Ok(())) when no buffered items remain and the sink has been successfully
/// closed.
/// Returns `Poll::Ready(Ok(()))` when no buffered items remain.
fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
let mut this = self.project();
loop {
@ -599,6 +598,7 @@ where
fn poll_close(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
ready!(self.as_mut().poll_flush(cx))?;
ready!(self.project().inner.poll_close(cx))?;
Poll::Ready(Ok(()))
}