Struct RayonTaskHandle 

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

Tracked handle returned by crate::RayonExecutorService for accepted tasks.

This handle supports blocking Self::get, asynchronous .await, status inspection, and best-effort cancellation before a Rayon worker starts the task.

Implementations

impl<R, E> RayonTaskHandle<R, E>

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

where R: Send, E: Send,

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

Returns

The final task result reported through the underlying tracked task.

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

where R: Send, E: Send,

Attempts to retrieve the final result without blocking.

Returns

A ready result or the pending Rayon task handle.

pub fn cancel(&self) -> CancelResult

where R: Send, E: Send,

Attempts to cancel the task before any Rayon worker starts it.

Returns

The observed cancellation outcome.

pub fn is_done(&self) -> bool

where R: Send, E: Send,

Returns whether the task has reported completion.

Returns

true after the task has finished or has been cancelled.

pub fn status(&self) -> TaskStatus

Returns the currently observed task status.

Returns

The task’s pending, running, or terminal status.

Trait Implementations

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

fn into_future(self) -> Self::IntoFuture

Converts this 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 RayonTaskHandle<R, E>

where R: Send, E: Send,

fn is_done(&self) -> bool

Returns whether the inner tracked task is done.

fn get(self) -> TaskResult<R, E>

Blocks until the inner tracked task yields a final result.

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

Attempts to retrieve the inner tracked task result without blocking.

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

where R: Send, E: Send,

fn status(&self) -> TaskStatus

Returns the currently observed task status.

fn cancel(&self) -> CancelResult

Cancels the task through the owning service state.