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.