123456789101112131415161718192021222324 |
- import { asyncScheduler } from '../scheduler/async';
- import { operate } from '../util/lift';
- import { createOperatorSubscriber } from './OperatorSubscriber';
- export function timeInterval(scheduler) {
- if (scheduler === void 0) { scheduler = asyncScheduler; }
- return operate(function (source, subscriber) {
- var last = scheduler.now();
- source.subscribe(createOperatorSubscriber(subscriber, function (value) {
- var now = scheduler.now();
- var interval = now - last;
- last = now;
- subscriber.next(new TimeInterval(value, interval));
- }));
- });
- }
- var TimeInterval = (function () {
- function TimeInterval(value, interval) {
- this.value = value;
- this.interval = interval;
- }
- return TimeInterval;
- }());
- export { TimeInterval };
- //# sourceMappingURL=timeInterval.js.map
|