operator_buffer_count

Collect values into fixed-size buffers before emitting them.

Example

cargo run -p rx_core --example operator_buffer_count_example

let _s = (1..=25)
    .into_observable()
    .buffer_count(3)
    .subscribe(PrintObserver::new("buffer_count_operator"));

buffer_count_operator - next: [1, 2, 3]
buffer_count_operator - next: [4, 5, 6]
buffer_count_operator - next: [7, 8, 9]
buffer_count_operator - next: [10, 11, 12]
buffer_count_operator - next: [13, 14, 15]
buffer_count_operator - next: [16, 17, 18]
buffer_count_operator - next: [19, 20, 21]
buffer_count_operator - next: [22, 23, 24]
buffer_count_operator - next: [25]
buffer_count_operator - completed
buffer_count_operator - unsubscribed