Struct PartialExecutor 

pub struct PartialExecutor<T> { /* private fields */ }

Partial-results executor — every task runs to completion; per-task success/failure exposed in the returned map.

Constructed via Executor::with_partial_results.

Implementations

impl<T> PartialExecutor<T>

where T: Send + 'static,

pub fn with_cancellation(self, token: CancellationToken) -> Self

Attach a cancellation token. Cancelling it causes all tasks to abort.

pub fn with_timeout(self, timeout: Duration) -> Self

Apply an overall timeout.

Trait Implementations

impl<T> IntoFuture for PartialExecutor<T>

where T: Send + 'static,

type Output = Result<HashMap<&'static str, Result<T, Box<dyn Error + Send + Sync>>>, Error>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <PartialExecutor<T> as IntoFuture>::Output> + Send>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.