Sha256: 5d39db35c8d997c18ae40baa17e694ab0724b13681826d1f77cb7e2610215beb
Contents?: true
Size: 684 Bytes
Versions: 14
Compression:
Stored size: 684 Bytes
Contents
/**
* Records the timestamp for each value in an observable sequence.
*
* @example
* 1 - res = source.timestamp(); // produces { value: x, timestamp: ts }
* 2 - res = source.timestamp(Rx.Scheduler.timeout);
*
* @param {Scheduler} [scheduler] Scheduler used to compute timestamps. If not specified, the timeout scheduler is used.
* @returns {Observable} An observable sequence with timestamp information on values.
*/
observableProto.timestamp = function (scheduler) {
isScheduler(scheduler) || (scheduler = timeoutScheduler);
return this.map(function (x) {
return { value: x, timestamp: scheduler.now() };
});
};
Version data entries
14 entries across 7 versions & 1 rubygems