Struct TaskManager

pub struct TaskManager<GroupKey, Outcome> { /* private fields */ }

Tracks tasks at the global conductor level, as well as each individual cell level.

Implementations

impl<GroupKey, Outcome> TaskManager<GroupKey, Outcome>

where GroupKey: Clone + Eq + Hash + Send + Debug + 'static, Outcome: Send + 'static,

pub fn new( outcome_rx: Sender<(GroupKey, Outcome)>, parent_map: impl 'static + Send + Sync + Fn(&GroupKey) -> Option<GroupKey>, ) -> Self

pub fn new_instrumented( span: Span, outcome_rx: Sender<(GroupKey, Outcome)>, parent_map: impl 'static + Send + Sync + Fn(&GroupKey) -> Option<GroupKey>, ) -> Self

pub fn add_task<Fut: Future<Output = Outcome> + Send + 'static>( &mut self, key: GroupKey, f: impl FnOnce(StopListener) -> Fut + Send + 'static, )

Add a task to a group

pub fn stop_group(&mut self, key: &GroupKey) -> GroupStop

Remove a group, returning a future that can be waited upon for all tasks in that group to complete.