Function eventuals::pipe_async

pub fn pipe_async<E, F, Fut>(reader: E, f: F) -> PipeHandle where
    E: IntoReader,
    F: 'static + Send + FnMut(E::Output) -> Fut,
    Fut: Send + Future<Output = ()>, 

Similar to pipe, but allows for the side effect to be async. See also: pipe