Peerset should never return Ready(None) (#2684)

This commit is contained in:
Pierre Krieger
2019-05-27 20:08:03 +02:00
committed by Bastian Köcher
parent 672b72f44a
commit b10ecd7931
+1 -1
View File
@@ -433,7 +433,7 @@ impl Stream for Peerset {
return Ok(Async::Ready(Some(message)));
}
match try_ready!(self.rx.poll()) {
None => return Ok(Async::Ready(None)),
None => return Ok(Async::NotReady),
Some(action) => match action {
Action::AddReservedPeer(peer_id) => self.on_add_reserved_peer(peer_id),
Action::RemoveReservedPeer(peer_id) => self.on_remove_reserved_peer(peer_id),