wip joinset

Hyle-org · Feb 25, 2025 · 140bd91 · 140bd91
1 parent cb63acb
commit 140bd91
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/mempool.rs b/src/mempool.rs
@@ -34,6 +34,7 @@ use std::{
     sync::Arc,
 };
 use storage::{DataProposalVerdict, LaneEntry, Storage};
+use tokio::task::{futures, JoinHandle, JoinSet};
 // Pick one of the two implementations
 // use storage_memory::LanesStorage;
 use storage_fjall::LanesStorage;
@@ -112,6 +113,7 @@ pub struct MempoolStore {
 pub struct Mempool {
     bus: MempoolBusClient,
     file: Option<PathBuf>,
+    blocker: JoinSet<()>,
     conf: SharedConf,
     crypto: SharedBlstCrypto,
     metrics: MempoolMetrics,
@@ -235,6 +237,7 @@ impl Module for Mempool {
             bus,
             file: Some(ctx.common.config.data_directory.clone()),
             conf: ctx.common.config.clone(),
+            blocker: JoinSet::new()
             metrics,
             crypto: Arc::clone(&ctx.node.crypto),
             lanes: LanesStorage::new(