Rx.Observable.prototype.bufferWithTimeOrCount(timeSpan, count, [scheduler])
Projects each element of an observable sequence into a buffer that is completed when either it's full or a given amount of time has elapsed.
Arguments
timeSpan
(Number
): Maximum time length of a buffer.count
(Number
): Maximum element count of a buffer.[scheduler=Rx.Scheduler.timeout]
(Scheduler
): Scheduler to run buffer timers on. If not specified, the timeout scheduler is used.
Returns
(Observable
): An observable sequence of buffers.
Example
/* Hitting the count buffer first */
var source = Rx.Observable.interval(100)
.bufferWithTimeOrCount(500, 3)
.take(3);
var subscription = source.subscribe(
function (x) {
console.log('Next: ' + x.toString());
},
function (err) {
console.log('Error: ' + err);
},
function () {
console.log('Completed');
});
// => Next: 0,1,2
// => Next: 3,4,5
// => Next: 6,7,8
// => Completed
Location
File:
Dist:
Prerequisites:
rx
.time.jsrx.lite.js
| rx.lite.compat.js
NPM Packages:
NuGet Packages:
Unit Tests: