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) -> DelayForStep<S>

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::IdType: GenerateId + Send + 'static, B::Compact: Send + 'static, B: Sink<Task<B::Compact, B::Context, B::IdType>, Error = Err> + Unpin + Send + Sync + Clone + 'static + BackendExt, Err: Error + Send + Sync + 'static, S: Clone + Send + 'static + Step<Input, B>, S::Response: Send + 'static, B::Codec: Codec<Duration, Compact = B::Compact> + Codec<Input, Compact = B::Compact> + 'static, <B::Codec as Codec<Duration>>::Error: Into<BoxDynError>, B::Context: Send + 'static + MetadataExt<WorkflowContext>, Input: Send + '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.