Function futurize::mark_stream [−][src]
pub fn mark_stream<I, E, O, F>(f: F, o: O) -> MarkedStream<I, E, O, F> where
F: Stream<Item = I, Error = E>,
pub fn mark_stream<I, E, O, F>(f: F, o: O) -> MarkedStream<I, E, O, F> where
F: Stream<Item = I, Error = E>,