Trait eventuals::EventualExt

source · [−]
pub trait EventualExt: Sized + IntoReader {
    fn map<F, O, Fut>(self, f: F) -> Eventual<O>
    where
        F: 'static + Send + FnMut(Self::Output) -> Fut,
        O: Value,
        Fut: Send + Future<Output = O>,
    { ... }
    fn throttle(self, duration: Duration) -> Eventual<Self::Output> { ... }
    fn pipe<F>(self, f: F) -> PipeHandle
    where
        F: 'static + Send + FnMut(Self::Output),
    { ... }
    fn pipe_async<F, Fut>(self, f: F) -> PipeHandle
    where
        F: 'static + Send + FnMut(Self::Output) -> Fut,
        Fut: Send + Future<Output = ()>,
    { ... }
    fn map_with_retry<F, E, Ok, Err, Fut, FutE>(
        self, 
        f: F, 
        on_err: E
    ) -> Eventual<Ok>
    where
        F: 'static + Send + FnMut(Self::Output) -> Fut,
        E: 'static + Send + Sync + FnMut(Err) -> FutE,
        Ok: Value,
        Err: Value,
        Fut: Send + Future<Output = Result<Ok, Err>>,
        FutE: Send + Future<Output = ()>,
    { ... }
    fn init_with(self, value: Self::Output) -> Eventual<Self::Output> { ... }
}
Expand description

Fluent style API extensions for any Eventual reader.

Provided Methods

Implementors