Struct FoldStep 

pub struct FoldStep<S, F, Init> { /* private fields */ }

The fold step that folds over a collection of items.

Trait Implementations

impl<S: Clone, F: Clone, Init: Clone> Clone for FoldStep<S, F, Init>

fn clone(&self) -> FoldStep<S, F, Init>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug, F: Debug, Init: Debug> Debug for FoldStep<S, F, Init>

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

Formats the value using the given formatter.

impl<S, F, Input, I, Init, B, MetaErr, Err, CodecError> Step<I, B> for FoldStep<S, F, Init>

where F: Service<Task<(Init, Input), B::Context, B::IdType>, Response = Init> + Send + 'static + Clone, S: Step<Init, B>, B: BackendExt<Error = Err> + Send + Sync + Clone + Sink<Task<B::Compact, B::Context, B::IdType>, Error = Err> + Unpin + 'static, I: IntoIterator<Item = Input> + Send + 'static, B::Context: MetadataExt<FoldState, Error = MetaErr> + MetadataExt<WorkflowContext, Error = MetaErr> + Send + 'static, B::Codec: Codec<(Init, Vec<Input>), Error = CodecError, Compact = B::Compact> + Codec<Init, Error = CodecError, Compact = B::Compact> + Codec<I, Error = CodecError, Compact = B::Compact> + Codec<(Init, Input), Error = CodecError, Compact = B::Compact> + 'static, B::IdType: GenerateId + Send + 'static + Clone, Init: Default + Send + 'static, Err: Error + Send + Sync + 'static, CodecError: Error + Send + Sync + 'static, F::Error: Into<BoxDynError> + Send + 'static, MetaErr: Error + Send + Sync + 'static, F::Future: Send + 'static, B::Compact: Send + 'static, Input: Send + 'static,

type Response = Init

The response type produced by the step.

type Error = <F as Service<Task<(Init, Input), <B as Backend>::Context, <B as Backend>::IdType>>>::Error

The error type produced by the step.

fn register(&mut self, ctx: &mut WorkflowRouter<B>) -> Result<(), BoxDynError>

Register the step with the workflow router.