Use select_biased! in Peer to avoid non-determinism

This commit is contained in:
Max Brunsfeld 2021-07-08 22:09:02 -07:00
parent b2aa961b4f
commit 60ef74a18f

View File

@ -312,7 +312,7 @@ where
let read_message = self.reader.read_message().fuse();
futures::pin_mut!(read_message);
loop {
futures::select! {
futures::select_biased! {
incoming = read_message => match incoming {
Ok(incoming) => {
Self::handle_incoming_message(incoming, &self.peer, self.connection_id, &self.response_channels).await;