Struct DelayForStep 

pub struct DelayForStep<S> { /* private fields */ }

Step that delays execution by a specified duration

Trait Implementations

impl<S: Clone> Clone for DelayForStep<S>

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> Debug for DelayForStep<S>

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

Formats the value using the given formatter.

impl<Input, B, S, Err> Step<Input, B> for DelayForStep<S>

where B::Id: GenerateId + Send + Sync + 'static, B::Compact: Send + 'static, B: Sink<Task<B::Compact>, Error = Err> + WireFormatBackend + BackendConfig + Unpin + Send + Sync + Clone + 'static + Backend, Err: Error + Send + Sync + 'static, S: Clone + Send + Sync + 'static + Step<Input, B>, 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 + Send + Sync>

The error type produced by the step.

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

Register the step with the workflow router.