forked from ROMEO/nexosim
More idiomatic loop
This commit is contained in:
parent
5d61abd729
commit
3b4a3e9b0e
@ -80,12 +80,8 @@ impl Listener {
|
|||||||
|
|
||||||
/// Periodically scheduled function that processes external events.
|
/// Periodically scheduled function that processes external events.
|
||||||
async fn process(&mut self) {
|
async fn process(&mut self) {
|
||||||
loop {
|
while let Ok(message) = self.rx.try_recv() {
|
||||||
if let Ok(message) = self.rx.try_recv() {
|
self.message.send(message).await;
|
||||||
self.message.send(message).await;
|
|
||||||
} else {
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user