diff --git a/src/service/sending.rs b/src/service/sending.rs index 943bebbc..021bec20 100644 --- a/src/service/sending.rs +++ b/src/service/sending.rs @@ -196,24 +196,27 @@ impl Service { loop { select! { - Some(response) = futures.next() => - if let Some(HandlerInputs { kind, events }) = - self.handle_response( - response, - &mut current_transaction_status, - )? - { + Some(response) = futures.next() => { + if let Some(HandlerInputs { + kind, + events, + }) = self.handle_response( + response, + &mut current_transaction_status, + )? { futures.push(Self::handle_events(kind, events)); - }, - Some(data) = receiver.recv() => - if let Some(HandlerInputs { kind, events }) = - self.handle_receiver( - data, - &mut current_transaction_status, - ) + } + } + Some(data) = receiver.recv() => { + if let Some(HandlerInputs { + kind, + events, + }) = self + .handle_receiver(data, &mut current_transaction_status) { futures.push(Self::handle_events(kind, events)); } + } } } }