Module buffer_with_count 

Structs

BufferWithCount

Periodically gathers items from an Observable into bundles and emits these bundles as Vec<T>, when the bundle reaches a specified size. See https://reactivex.io/documentation/operators/buffer.html