pub fn coalesce<S: Stream, F>(stream: S, f: F) -> Coalesce<S, F>where F: FnMut(S::Item, S::Item) -> Result<S::Item, (S::Item, S::Item)>,