Struct DelayWithStep 

pub struct DelayWithStep<S, F, B, Input> { /* private fields */ }

Step that delays execution by a specified duration

Trait Implementations

impl<S: Clone, F: Clone, B, Input> Clone for DelayWithStep<S, F, B, Input>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug, F: Debug, B: Debug, Input: Debug> Debug for DelayWithStep<S, F, B, Input>

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

Formats the value using the given formatter.

impl<S, F, B, Input, Err> Service<Task<<B as WireFormatBackend>::Compact>> for DelayWithStep<S, F, B, Input>

where F: FnMut(Task<Input>) -> Duration + Send + 'static + Clone, S: Step<Input, B> + Send + 'static, S::Response: Send + 'static, B::Id: GenerateId + Sync + Send + 'static, B::Compact: Send + 'static, B: Sink<Task<B::Compact>, Error = Err> + WireFormatBackend + BackendConfig + Unpin + Send + Sync + Backend + 'static + Clone, Err: Error + Send + Sync + 'static, B::Codec: Codec<Duration, Compact = B::Compact> + Codec<Input, Compact = B::Compact> + Send + Clone + 'static, <B::Codec as Codec<Duration>>::Error: Into<BoxDynError>, <B::Codec as Codec<Input>>::Error: Into<BoxDynError>,

type Response = GoTo<StepResponse>

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<<DelayWithStep<S, F, B, Input> as Service<Task<<B as WireFormatBackend>::Compact>>>::Response, <DelayWithStep<S, F, B, Input> as Service<Task<<B as WireFormatBackend>::Compact>>>::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, req: Task<B::Compact>) -> Self::Future

Process the request and return the response asynchronously.

impl<Input, F, B, S, Err> Step<Input, B> for DelayWithStep<S, F, B, Input>

where F: FnMut(Task<Input>) -> Duration + Send + Sync + 'static + Clone, B::Id: GenerateId + Sync + Send + 'static, B::Compact: Send + 'static, B: Sink<Task<B::Compact>, Error = Err> + BackendConfig + WireFormatBackend + Unpin + Send + Sync + Clone + 'static + Backend, Err: Error + Send + Sync + 'static, S: Step<Input, B> + Clone + Send + Sync + 'static, S::Response: Send + 'static, B::Codec: Codec<Duration, Compact = B::Compact> + Codec<Input, Compact = B::Compact> + Send + Clone + 'static, <B::Codec as Codec<Duration>>::Error: Into<BoxDynError>, Input: Send + Sync + 'static, <B::Codec as Codec<Input>>::Error: Into<BoxDynError>,

type Response = Input

The response type produced by the step.

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

The error type produced by the step.

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

Register the step with the workflow router.