Struct DelayStep 

pub struct DelayStep<S, T> { /* private fields */ }

Implementations

impl<S, T> DelayStep<S, T>

pub fn new(inner: S) -> Self

Trait Implementations

impl<S: Clone, T> Clone for DelayStep<S, T>

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, T: Debug> Debug for DelayStep<S, T>

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

Formats the value using the given formatter.

impl<Current, FlowSink, Encode, Compact> Step<Current, FlowSink, Encode> for DelayStep<Duration, Current>

where Current: Sync + Send + 'static, FlowSink: Sync + Unpin + WeakTaskSink<Current> + Send, FlowSink::Context: Send + Sync + Default + MetadataExt<WorkflowRequest>, FlowSink::Error: Into<BoxDynError> + Send + 'static, FlowSink::IdType: GenerateId + Send, Compact: Sync + Send, Encode: Codec<Current, Compact = Compact> + Sync + Send + 'static, Encode::Error: Error + Sync + Send + 'static, <FlowSink::Context as MetadataExt<WorkflowRequest>>::Error: Error + Sync + Send + 'static,

type Response = Current

type Error = Infallible

async fn run( &mut self, _: &StepContext<FlowSink, Encode>, task: Task<Current, FlowSink::Context, FlowSink::IdType>, ) -> Result<GoTo<Current>, Self::Error>