|
|
@@ -42,6 +42,7 @@ impl IndProgress {
|
|
|
|
|
|
// type BoxFuture<T> = Pin<Box<dyn Future<Output = T> + Send>>;
|
|
|
|
|
|
+#[derive(Clone, Debug)]
|
|
|
pub struct TaskManager<R> {
|
|
|
tasks: Arc<Mutex<HashMap<usize, task::JoinHandle<anyhow::Result<()>>>>>,
|
|
|
results_channels: Arc<Mutex<HashMap<usize, Receiver<R>>>>,
|
