From d41716d8f01b19d0498e05914c4b6e0fd6e84eca Mon Sep 17 00:00:00 2001 From: Louis Dureuil Date: Thu, 2 Oct 2025 16:50:44 +0200 Subject: [PATCH] Add `MustStopProcessing::as_lambda` --- crates/index-scheduler/src/scheduler/mod.rs | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/crates/index-scheduler/src/scheduler/mod.rs b/crates/index-scheduler/src/scheduler/mod.rs index c57bbf70d..b32cd6e40 100644 --- a/crates/index-scheduler/src/scheduler/mod.rs +++ b/crates/index-scheduler/src/scheduler/mod.rs @@ -50,6 +50,11 @@ impl MustStopProcessing { pub fn reset(&self) { self.0.store(false, Ordering::Relaxed); } + + pub fn as_lambda(&self) -> impl Fn() -> bool + Send + Sync + 'static { + let clone = self.clone(); + move || clone.get() + } } pub struct Scheduler {