rustfmt
This commit is contained in:
parent
5ec8d09e0d
commit
9d9734ea81
|
@ -378,15 +378,11 @@ impl State {
|
||||||
.instrument(span.clone())
|
.instrument(span.clone())
|
||||||
.await
|
.await
|
||||||
{
|
{
|
||||||
Either::Left((None, _)) => {
|
Either::Left((None, _)) => Transition::ExitResponse {
|
||||||
Transition::ExitResponse {
|
e: PeerError::ConnectionClosed.into(),
|
||||||
e: PeerError::ConnectionClosed.into(),
|
tx,
|
||||||
tx,
|
},
|
||||||
}
|
Either::Left((Some(Err(e)), _)) => Transition::ExitResponse { e: e.into(), tx },
|
||||||
}
|
|
||||||
Either::Left((Some(Err(e)), _)) => {
|
|
||||||
Transition::ExitResponse { e: e.into(), tx }
|
|
||||||
}
|
|
||||||
Either::Left((Some(Ok(peer_msg)), _cancel)) => {
|
Either::Left((Some(Ok(peer_msg)), _cancel)) => {
|
||||||
let request_msg = span.in_scope(|| handler.process_message(peer_msg));
|
let request_msg = span.in_scope(|| handler.process_message(peer_msg));
|
||||||
// If the message was not consumed, check whether it
|
// If the message was not consumed, check whether it
|
||||||
|
|
Loading…
Reference in New Issue