mirror of
https://gitlab.computer.surgery/matrix/grapevine.git
synced 2025-12-17 07:41:23 +01:00
sending.rs: formatting
This commit is contained in:
parent
aa69b7d15c
commit
5caafdec06
1 changed files with 17 additions and 14 deletions
|
|
@ -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));
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue