operators/timeInterval.js

   1 "use strict";
   2 Object.defineProperty(exports, "__esModule", { value: true });
   3 var async_1 = require("../scheduler/async");
   4 var scan_1 = require("./scan");
   5 var defer_1 = require("../observable/defer");
   6 var map_1 = require("./map");
   7 function timeInterval(scheduler) {
   8     if (scheduler === void 0) { scheduler = async_1.async; }
   9     return function (source) { return defer_1.defer(function () {
  10         return source.pipe(scan_1.scan(function (_a, value) {
  11             var current = _a.current;
  12             return ({ value: value, current: scheduler.now(), last: current });
  13         }, { current: scheduler.now(), value: undefined, last: undefined }), map_1.map(function (_a) {
  14             var current = _a.current, last = _a.last, value = _a.value;
  15             return new TimeInterval(value, current - last);
  16         }));
  17     }); };
  18 }
  19 exports.timeInterval = timeInterval;
  20 var TimeInterval = (function () {
  21     function TimeInterval(value, interval) {
  22         this.value = value;
  23         this.interval = interval;
  24     }
  25     return TimeInterval;
  26 }());
  27 exports.TimeInterval = TimeInterval;
  28 //# sourceMappingURL=timeInterval.js.map