Function vector::test_util::collect_n_stream

pub async fn collect_n_stream<T, S: Stream<Item = T> + Unpin>(
    stream: &mut S,
    n: usize,
) -> Vec<T>