Function futures_util::stream::assert_stream

pub(crate) fn assert_stream<T, S>(stream: S) -> Swhere
    S: Stream<Item = T>,