Function futures_async_combinators::stream::filter_map

pub fn filter_map<St, Fut, F, U>(stream: St, f: F) -> impl Stream<Item = U> where
    St: Stream,
    F: FnMut(St::Item) -> Fut,
    Fut: Future<Output = Option<U>>,