buffer
Buffers the source Observable values until closingNotifier
emits.
Collects values from the past as an array, and emits that array only when another Observable emits.
Buffers the incoming Observable values until the given closingNotifier
ObservableInput
(that internally gets converted to an Observable)
emits a value, at which point it emits the buffer on the output
Observable and starts a new buffer internally, awaiting the next time
closingNotifier
emits.
Example
On every click, emit array of most recent interval events
import { fromEvent, interval, buffer } from 'rxjs';
const clicks = fromEvent(document, 'click');
const intervalEvents = interval(1000);
const buffered = intervalEvents.pipe(buffer(clicks));
buffered.subscribe(x => console.log(x));
§
§Parameters
§
closingNotifier: ObservableInput<any>
[src]An ObservableInput
that signals the
buffer to be emitted on the output Observable.
§Return Type
§
OperatorFunction<T, T[]>
[src]A function that returns an Observable of buffers, which are arrays of values.