Trait async_pipeline::link::Pipeline

pub trait Pipeline: Linkable {
    type IN: Send + Sync;

    fn process<'life0, 'async_trait>(
        &'life0 self,
        input: Self::IN
    ) -> Pin<Box<dyn Future<Output = Result<Self::OUT, Error>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}

Required Associated Types

type IN: Send + Sync

Required Methods

fn process<'life0, 'async_trait>(
    &'life0 self,
    input: Self::IN
) -> Pin<Box<dyn Future<Output = Result<Self::OUT, Error>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    Self: 'async_trait,

Implementors

impl<NXT, F, IN> Pipeline for Connect<Start<IN>, ErrorFuc<F>>where
    IN: Sync + Send,
    F: Fn(IN) -> Result<NXT, Error> + Sync + Send,
    NXT: Send + Sync,

type IN = IN

impl<NXT, F, IN> Pipeline for Connect<Start<IN>, F>where
    F: Fn(IN) -> NXT + Send + Sync,
    NXT: Send + Sync,
    IN: Send + Sync,

type IN = IN

impl<NXT, F, P> Pipeline for Connect<P, ErrorFuc<F>>where
    P: Pipeline + Sync + Send,
    F: Fn(P::OUT) -> Result<NXT, Error> + Sync + Send,
    NXT: Send + Sync,

type IN = <P as Pipeline>::IN

impl<NXT, F, P> Pipeline for Connect<P, F>where
    P: Pipeline + Sync + Send,
    F: Fn(P::OUT) -> NXT + Sync + Send,
    NXT: Send + Sync,

type IN = <P as Pipeline>::IN

impl<NXT, Fut, F, IN> Pipeline for AsyncConnect<Start<IN>, ErrorFuc<F>>where
    IN: Sync + Send,
    F: Fn(IN) -> Fut + Sync + Send,
    Fut: Future<Output = Result<NXT, Error>> + Send + Sync + 'static,
    NXT: Send + Sync,

type IN = IN

impl<NXT, Fut, F, IN> Pipeline for AsyncConnect<Start<IN>, F>where
    F: Fn(IN) -> Fut + 'static + Send + Sync,
    Fut: Future<Output = NXT> + Send + Sync + 'static,
    NXT: Send + Sync,
    IN: Send + Sync,

type IN = IN

impl<NXT, Fut, F, P> Pipeline for AsyncConnect<P, ErrorFuc<F>>where
    F: Fn(P::OUT) -> Fut + Send + Sync,
    Fut: Future<Output = Result<NXT, Error>> + Send + Sync + 'static,
    NXT: Send + Sync,
    P: Pipeline + Send + Sync,

type IN = <P as Pipeline>::IN

impl<NXT, Fut, F, P> Pipeline for AsyncConnect<P, F>where
    P: Pipeline + Sync + Send,
    F: Fn(P::OUT) -> Fut + 'static + Send + Sync,
    Fut: Future<Output = NXT> + Send + Sync + 'static,
    NXT: Send + Sync,

type IN = <P as Pipeline>::IN