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 TaskSlot 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, slot: TaskSlot<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 before the runner started.

pub fn run_detached<R, E>(self)

where C: Callable<R, E>,

Runs this task and discards its final result.

This is intended for detached runnable submissions whose caller only observes acceptance. The callable is still wrapped in panic conversion, but success, task failure, and panic results are intentionally dropped.