Struct TaskRunner 

pub struct TaskRunner<C> { /* private fields */ }

Runner that executes a callable task with standard task-handle semantics.

TaskRunner owns the accepted callable, converts task failures and panics into TaskExecutionError, and can publish the final result through a TaskCompletion endpoint.

Implementations

impl<C> TaskRunner<C>

pub const fn new(task: C) -> Self

Creates a runner for the supplied callable task.

Parameters

• task - Callable task to execute later.

Returns

A runner that owns the callable task.

pub fn call<R, E>(self) -> TaskResult<R, E>

where C: Callable<R, E>,

Runs the callable and converts task failure and panic into a handle result.

Returns

Ok(R) if the task succeeds. If the task returns Err(E) or panics, the corresponding TaskExecutionError is returned.

pub fn run<R, E>(self, completion: TaskCompletion<R, E>) -> bool

where C: Callable<R, E>,

Runs this task through a task completion endpoint.

Parameters

• completion - Completion endpoint that publishes the final result.

Returns

true if the task started and its result was published, or false if the completion endpoint had already been completed by cancellation.