snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-10-10 13:46:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add MustStopProcessing::as_lambda

Browse Source
This commit is contained in:
Louis Dureuil
2025-10-02 16:50:44 +02:00
parent 43a6505435
commit d41716d8f0
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
crates/index-scheduler/src/scheduler/mod.rs
View File

@@ -50,6 +50,11 @@ impl MustStopProcessing {
pub fn reset(&self) { pub fn reset(&self) {
self.0.store(false, Ordering::Relaxed); 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 { pub struct Scheduler {