diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-06-21 18:04:03 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-06-21 18:04:03 +0200 |
| commit | 8fb8569912745ea90e8d0dd8313b431774780ad2 (patch) | |
| tree | d5fdeb6efcfe50819b596c0333842989ac6a0abf | |
| parent | 708dab6e0ff8c2dab5cac39a1f64a5e391c32137 (diff) | |
| download | garage-8fb8569912745ea90e8d0dd8313b431774780ad2.tar.gz garage-8fb8569912745ea90e8d0dd8313b431774780ad2.zip | |
fix clippy
| -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(); |