This commit is contained in:
Milo Turner 2020-03-10 20:58:14 -04:00
parent f48846f325
commit 847d327d58
1 changed files with 3 additions and 3 deletions

View File

@ -161,13 +161,13 @@ where
_ = timer => Evt::Timer, _ = timer => Evt::Timer,
r = peer.recv() => match r { r = peer.recv() => match r {
Ok(m) => Evt::Recv(m), Ok(m) => Evt::Recv(m),
Err(peer::RecvError::Io { source }) => {
return Err(source.into());
}
Err(peer::RecvError::InvalidMessage { .. }) => { Err(peer::RecvError::InvalidMessage { .. }) => {
log.recv_corrupt().await; log.recv_corrupt().await;
continue; continue;
} }
Err(peer::RecvError::Io { source }) => {
return Err(source.into());
}
} }
); );