futures_async_combinators::stream
pub fn take<St>(stream: St, n: u64) -> impl Stream<Item = St::Item> where St: Stream,