diff options
| -rw-r--r-- | src/table/sync.rs | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/table/sync.rs b/src/table/sync.rs index bdf88782..a331ec75 100644 --- a/src/table/sync.rs +++ b/src/table/sync.rs @@ -597,11 +597,10 @@ impl<F: TableSchema + 'static, R: TableReplication + 'static> Worker for SyncWor async fn wait_for_work(&mut self, _must_exit: &watch::Receiver<bool>) -> WorkerStatus { select! { - s = self.add_full_sync_rx.recv() => match s { - Some(()) => { + s = self.add_full_sync_rx.recv() => { + if let Some(()) = s { self.add_full_sync(); } - None => (), }, _ = self.ring_recv.changed() => { let new_ring = self.ring_recv.borrow(); |