Struct FilterMapStep 

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

Implementations

impl<S, T, O> FilterMapStep<S, T, O>

pub fn new(inner: S) -> Self

Trait Implementations

impl<S: Clone, T, O> Clone for FilterMapStep<S, T, O>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, T, O, E, B, Compact, Encode> Step<T, B, Encode> for FilterMapStep<S, T, O>

where S: Service<Task<T, B::Context, B::IdType>, Response = Option<O>, Error = E> + Sync + Send, T: Sync + Send, S::Future: Send + 'static, S::Error: Into<BoxDynError>, E: Into<BoxDynError>, O: Sync + Send, B: Sync + Send + 'static + WeakTaskSink<Option<O>>, B::Context: Send + Sync, B::IdType: Send, Compact: Send + Sync, Encode: Codec<T, Compact = Compact> + Sync,

type Response = <S as Service<Task<T, <B as Backend>::Context, <B as Backend>::IdType>>>::Response

type Error = Box<dyn Error + Send + Sync>

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