Struct TrackedTask 

pub struct TrackedTask<R, E> { /* private fields */ }

Result handle with active status tracking and pre-start cancellation.

Implementations

impl<R, E> TrackedTask<R, E>

pub fn get(self) -> Result<R, TaskExecutionError<E>>

where R: Send, E: Send,

Waits for the task to finish and returns its final result.

Returns

The final task result.

pub fn try_get(self) -> TryGet<TrackedTask<R, E>, R, E>

where R: Send, E: Send,

Attempts to retrieve the final result without blocking.

Returns

A ready result or the pending tracked handle.

pub fn is_done(&self) -> bool

where R: Send, E: Send,

Returns whether the tracked task has installed a terminal state.

Returns

true after the task succeeds, fails, panics, is cancelled, or loses its completion endpoint. The final result send may still be racing with this status observation.

pub fn status(&self) -> TaskStatus

Returns the currently observed task status.

Returns

The current task status.

pub fn task_id(&self) -> TaskId

Returns the identifier assigned to this task.

Returns

The task id stored in the shared task state.

pub fn cancel(&self) -> CancelResult

Attempts to cancel this task before it starts.

Returns

The observed cancellation outcome.

Trait Implementations

impl<R, E> IntoFuture for TrackedTask<R, E>

fn into_future(self) -> <TrackedTask<R, E> as IntoFuture>::IntoFuture

Converts this tracked handle into a future resolving to the task result.

type Output = Result<R, TaskExecutionError<E>>

The output that the future will produce on completion.

type IntoFuture = TaskHandleFuture<R, E>

Which kind of future are we turning this into?

impl<R, E> TaskResultHandle<R, E> for TrackedTask<R, E>

where R: Send, E: Send,

fn is_done(&self) -> bool

Returns whether the tracked state is terminal.

fn get(self) -> Result<R, TaskExecutionError<E>>

Blocks until the underlying result handle yields a result.

fn try_get(self) -> TryGet<TrackedTask<R, E>, R, E>

Attempts to retrieve the underlying result without blocking.

impl<R, E> TrackedTaskHandle<R, E> for TrackedTask<R, E>

where R: Send, E: Send,

fn status(&self) -> TaskStatus

Returns the currently observed task status.

fn cancel(&self) -> CancelResult

Attempts to publish a cancellation result while the task is pending.