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