Struct FoldService 

pub struct FoldService<F, Init, I, B> { /* private fields */ }

The fold service that handles folding over a collection of items.

Implementations

impl<F, Init, I, B> FoldService<F, Init, I, B>

pub fn new(fold: F) -> Self

Creates a new FoldService with the given fold function.

Trait Implementations

impl<F: Clone, Init: Clone, I: Clone, B: Clone> Clone for FoldService<F, Init, I, B>

fn clone(&self) -> FoldService<F, Init, I, B>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<F: Debug, Init: Debug, I: Debug, B: Debug> Debug for FoldService<F, Init, I, B>

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

Formats the value using the given formatter.

impl<F, Init, I, B, Input, CodecError, MetaErr, Err> Service<Task<<B as BackendExt>::Compact, <B as Backend>::Context, <B as Backend>::IdType>> for FoldService<F, Init, I, B>

where F: Service<Task<(Init, Input), B::Context, B::IdType>, Response = Init> + Send + 'static + Clone, 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, 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 = GoTo<StepResult<<B as BackendExt>::Compact, <B as Backend>::IdType>>

Responses given by the service.

type Error = Box<dyn Error + Sync + Send>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<FoldService<F, Init, I, B> as Service<Task<<B as BackendExt>::Compact, <B as Backend>::Context, <B as Backend>::IdType>>>::Response, <FoldService<F, Init, I, B> as Service<Task<<B as BackendExt>::Compact, <B as Backend>::Context, <B as Backend>::IdType>>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call( &mut self, task: Task<B::Compact, B::Context, B::IdType>, ) -> Self::Future

Process the request and return the response asynchronously.