Struct ThenStep 

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

Implementations

impl<S, T> ThenStep<S, T>

pub fn new(inner: S) -> Self

Trait Implementations

impl<S: Clone, T> Clone for ThenStep<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 ThenStep<S, T>

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

Formats the value using the given formatter.

impl<S, Current, O, E, FlowSink, Encode, Compact> Step<Current, FlowSink, Encode> for ThenStep<S, Current>

where S: Service<Task<Current, FlowSink::Context, FlowSink::IdType>, Response = O, Error = E> + Sync + Send, Current: Sync + Send + 'static, S::Future: Send + 'static, S::Error: Into<BoxDynError>, E: Into<BoxDynError> + Send + Sync + 'static, O: Sync, FlowSink: Sync + Unpin + WeakTaskSink<O> + 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 = <S as Service<Task<Current, <FlowSink as Backend>::Context, <FlowSink as Backend>::IdType>>>::Response

type Error = <S as Service<Task<Current, <FlowSink as Backend>::Context, <FlowSink as Backend>::IdType>>>::Error

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