Struct zenoh_task::TerminatableTask

pub struct TerminatableTask { /* private fields */ }

Implementations

impl TerminatableTask

pub fn create_cancellation_token() -> CancellationToken

pub fn spawn<F, T>( rt: ZRuntime, future: F, token: CancellationToken, ) -> TerminatableTask

where F: Future<Output = T> + Send + 'static, T: Send + 'static,

Spawns a task that can be later terminated by TerminatableTask::terminate(). Prior to termination attempt the specified cancellation token will be cancelled.

pub fn spawn_abortable<F, T>(rt: ZRuntime, future: F) -> TerminatableTask

where F: Future<Output = T> + Send + 'static, T: Send + 'static,

Spawns a task that can be later aborted by TerminatableTask::terminate().

pub fn terminate(self, timeout: Duration) -> bool

Attempts to terminate the task. Returns true if task completed / aborted within timeout duration, false otherwise.

pub async fn terminate_async(self, timeout: Duration) -> bool

Async version of TerminatableTask::terminate().