Struct RepeatUntilService 

pub struct RepeatUntilService<F, B, Input, Output> { /* private fields */ }

The service that handles the repeat_until logic

Trait Implementations

impl<F, B, Input, Output> Clone for RepeatUntilService<F, B, Input, Output>

where F: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<F: Debug, B: Debug, Input: Debug, Output: Debug> Debug for RepeatUntilService<F, B, Input, Output>

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

Formats the value using the given formatter.

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

where F: Service<Task<Input, B::Context, B::IdType>, Response = Option<Res>> + Send + 'static + Clone, B: BackendExt<Error = Err> + Send + Sync + Clone + Sink<Task<B::Compact, B::Context, B::IdType>, Error = Err> + Unpin + 'static, B::Context: MetadataExt<RepeaterState<B::IdType>, Error = MetaErr> + MetadataExt<WorkflowContext, Error = MetaErr> + Send + 'static, B::Codec: Codec<Input, Error = CodecError, Compact = B::Compact> + Codec<Res, Error = CodecError, Compact = B::Compact> + Codec<Option<Res>, Error = CodecError, Compact = B::Compact> + 'static, B::IdType: GenerateId + 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, Res: 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<<RepeatUntilService<F, B, Input, Res> as Service<Task<<B as BackendExt>::Compact, <B as Backend>::Context, <B as Backend>::IdType>>>::Response, <RepeatUntilService<F, B, Input, Res> 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.