Trait par_stream::builder::FutureFactory

pub trait FutureFactory<In> where
    In: 'static + Send,
    Self::Fut: 'static + Send + Future,
    <Self::Fut as Future>::Output: 'static + Send, {
    type Fut;
    fn generate(&mut self, input: In) -> Self::Fut;

    fn boxed<'a>(
        self
    ) -> BoxFutureFactory<'a, In, <Self::Fut as Future>::Output>
    where
        Self: 'a + Sized + Send,
    { ... }
    fn compose<G>(self, other: G) -> ComposeFutureFactory<In, Self, G>
    where
        Self: Sized,
        G: 'static + Send + Clone + FutureFactory<<Self::Fut as Future>::Output>,
        <G::Fut as Future>::Output: Send,
    { ... }
}

Associated Types

type Fut

Required methods

fn generate(&mut self, input: In) -> Self::Fut

Provided methods

fn boxed<'a>(self) -> BoxFutureFactory<'a, In, <Self::Fut as Future>::Output> where
    Self: 'a + Sized + Send, 

fn compose<G>(self, other: G) -> ComposeFutureFactory<In, Self, G> where
    Self: Sized,
    G: 'static + Send + Clone + FutureFactory<<Self::Fut as Future>::Output>,
    <G::Fut as Future>::Output: Send, 

Implementors

impl<F, In, Fut> FutureFactory<In> for F where
    F: FnMut(In) -> Fut,
    In: 'static + Send,
    Fut: 'static + Send + Future,
    Fut::Output: 'static + Send, 

type Fut = Fut

impl<In, F, G> FutureFactory<In> for ComposeFutureFactory<In, F, G> where
    F: FutureFactory<In>,
    G: 'static + Send + Clone + FutureFactory<<F::Fut as Future>::Output>,
    In: 'static + Send,
    <F::Fut as Future>::Output: 'static + Send,
    <G::Fut as Future>::Output: 'static + Send,
    F::Fut: 'static + Send + Future,
    G::Fut: 'static + Send + Future, 

type Fut = FutFacChain<F::Fut, G>