vector::test_util

Function collect_n_stream

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