Struct AndThenStep 

pub struct AndThenStep<F, S> { /* private fields */ }

The step implementation for the AndThen layer.

Trait Implementations

impl<F: Clone, S: Clone> Clone for AndThenStep<F, S>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<F: Debug, S: Debug> Debug for AndThenStep<F, S>

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

Formats the value using the given formatter.

impl<F, Input, S, B, CodecError, Err> Step<Input, B> for AndThenStep<F, S>

where B: Backend<Error = Err> + WireFormatBackend + BackendConfig + Sink<Task<B::Compact>, Error = Err> + Send + Sync + Unpin + Clone + 'static, F: Service<Task<Input>, Error = BoxDynError> + Send + Sync + 'static + Clone, S: Step<F::Response, B>, Input: Send + Sync + 'static, F::Future: Send + 'static, F::Error: Into<BoxDynError> + Send + 'static, B::Codec: Codec<F::Response, Error = CodecError, Compact = B::Compact> + Codec<Input, Error = CodecError, Compact = B::Compact> + Codec<S::Response, Error = CodecError, Compact = B::Compact> + Send + Sync + Clone + 'static, CodecError: Error + Send + Sync + 'static, B::Id: GenerateId + Send + Sync + 'static, S::Response: Send + 'static, B::Compact: Send + 'static, F::Response: Send + Serialize + 'static, Err: Error + Send + Sync + 'static,

type Response = <F as Service<Task<Input>>>::Response

The response type produced by the step.

type Error = <F as Service<Task<Input>>>::Error

The error type produced by the step.

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

Register the step with the workflow router.