Sha256: e6fcc6190866f9fcdbf58e0ddf00887ae9bafabe35b3172edb21a13096695488
Contents?: true
Size: 847 Bytes
Versions: 14
Compression:
Stored size: 847 Bytes
Contents
/**
* Records the time interval between consecutive values in an observable sequence.
*
* @example
* 1 - res = source.timeInterval();
* 2 - res = source.timeInterval(Rx.Scheduler.timeout);
*
* @param [scheduler] Scheduler used to compute time intervals. If not specified, the timeout scheduler is used.
* @returns {Observable} An observable sequence with time interval information on values.
*/
observableProto.timeInterval = function (scheduler) {
var source = this;
isScheduler(scheduler) || (scheduler = timeoutScheduler);
return observableDefer(function () {
var last = scheduler.now();
return source.map(function (x) {
var now = scheduler.now(), span = now - last;
last = now;
return { value: x, interval: span };
});
});
};
Version data entries
14 entries across 7 versions & 1 rubygems