Struct ParallelScope 

pub struct ParallelScope<'a> { /* private fields */ }

A handle for spawning durable steps with eagerly-assigned, contiguous step ids.

Returned by DurableContext::parallel. Each step call assigns its id synchronously, before returning the future, so building a batch of children fixes their ids in construction order — completion order is then irrelevant (INV-2).

Implementations

impl<'a> ParallelScope<'a>

pub fn step<T, F, Fut>( &self, desc: StepDescriptor, op: F, ) -> impl Future<Output = Result<DurableStep<T>, DurableError>> + Send + 'a

where T: Serialize + DeserializeOwned + Send + 'a, F: FnOnce(StepHandle) -> Fut + Send + 'a, Fut: Future<Output = Result<T, StepError>> + Send + 'a,

Construct a durable step future with its id assigned eagerly.

The returned future runs (or replays) the step when awaited; its StepId is already fixed. Collect the futures synchronously, then await them concurrently.

Errors

The awaited future fails for the same reasons as DurableContext::step.

Trait Implementations

impl<'a> Clone for ParallelScope<'a>

fn clone(&self) -> ParallelScope<'a>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a> Copy for ParallelScope<'a>

impl<'a> Debug for ParallelScope<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.