Function futures_async_combinators::stream::for_each

pub async fn for_each<St, Fut, F>(stream: St, f: F) where
    St: Stream,
    F: FnMut(St::Item) -> Fut,
    Fut: Future<Output = ()>,