Simplify reaper setup

djc · Jan 29, 2024 · 9911e8e · 9911e8e
1 parent 2699ff6
commit 9911e8e
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/bb8/src/inner.rs b/bb8/src/inner.rs
@@ -27,12 +27,9 @@ where
         let inner = Arc::new(SharedPool::new(builder, manager));
 
         if inner.statics.max_lifetime.is_some() || inner.statics.idle_timeout.is_some() {
-            let s = Arc::downgrade(&inner);
-            if let Some(shared) = s.upgrade() {
-                let start = Instant::now() + shared.statics.reaper_rate;
-                let interval = interval_at(start.into(), shared.statics.reaper_rate);
-                schedule_reaping(interval, s);
-            }
+            let start = Instant::now() + inner.statics.reaper_rate;
+            let interval = interval_at(start.into(), inner.statics.reaper_rate);
+            schedule_reaping(interval, Arc::downgrade(&inner));
         }
 
         Self { inner }