Struct TaskManagerHandle 

pub struct TaskManagerHandle { /* private fields */ }

Implementations

impl TaskManagerHandle

pub async fn next_event(&self) -> Option<TaskEvent>

pub async fn cancel(&self, task_id: TaskId) -> Result<(), TaskManagerError>

pub async fn list_running(&self) -> Vec<TaskSnapshot>

pub async fn list_completed(&self) -> Vec<TaskSnapshot>

pub async fn drain_ready_items(&self) -> Vec<Item>

pub async fn set_continue_policy( &self, task_id: TaskId, policy: ContinuePolicy, ) -> Result<(), TaskManagerError>

pub async fn set_delivery_mode( &self, task_id: TaskId, mode: DeliveryMode, ) -> Result<(), TaskManagerError>

pub async fn wait_for_idle(&self)

Wait until all running tasks have completed.

Trait Implementations

impl Clone for TaskManagerHandle

fn clone(&self) -> TaskManagerHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.