Function buffer 

pub fn buffer<T, S: Stream<Item = T>>(
    size: usize,
    s: S,
) -> impl Stream<Item = Vec<T>>