pub fn buffer_count<T: Clone + 'static>(count: usize) -> Operator<Vec<T>>
buffer_count: emit chunks of count, flushing the remainder on source COMPLETE.
count