diff --git a/zebra-network/src/peer/connection.rs b/zebra-network/src/peer/connection.rs index adfa52d43..aca6fd955 100644 --- a/zebra-network/src/peer/connection.rs +++ b/zebra-network/src/peer/connection.rs @@ -378,11 +378,15 @@ impl State { .instrument(span.clone()) .await { - Either::Left((None, _)) => Transition::ExitResponse { - e: PeerError::ConnectionClosed.into(), - tx, - }, - Either::Left((Some(Err(e)), _)) => Transition::ExitResponse { e: e.into(), tx }, + Either::Left((None, _)) => { + Transition::ExitResponse { + e: PeerError::ConnectionClosed.into(), + tx, + } + } + Either::Left((Some(Err(e)), _)) => { + Transition::ExitResponse { e: e.into(), tx } + } Either::Left((Some(Ok(peer_msg)), _cancel)) => { let request_msg = span.in_scope(|| handler.process_message(peer_msg)); // If the message was not consumed, check whether it