/** PURE_IMPORTS_START tslib,_Subscriber,_scheduler_async PURE_IMPORTS_END */
|
import * as tslib_1 from "tslib";
|
import { Subscriber } from '../Subscriber';
|
import { async } from '../scheduler/async';
|
export function sampleTime(period, scheduler) {
|
if (scheduler === void 0) {
|
scheduler = async;
|
}
|
return function (source) { return source.lift(new SampleTimeOperator(period, scheduler)); };
|
}
|
var SampleTimeOperator = /*@__PURE__*/ (function () {
|
function SampleTimeOperator(period, scheduler) {
|
this.period = period;
|
this.scheduler = scheduler;
|
}
|
SampleTimeOperator.prototype.call = function (subscriber, source) {
|
return source.subscribe(new SampleTimeSubscriber(subscriber, this.period, this.scheduler));
|
};
|
return SampleTimeOperator;
|
}());
|
var SampleTimeSubscriber = /*@__PURE__*/ (function (_super) {
|
tslib_1.__extends(SampleTimeSubscriber, _super);
|
function SampleTimeSubscriber(destination, period, scheduler) {
|
var _this = _super.call(this, destination) || this;
|
_this.period = period;
|
_this.scheduler = scheduler;
|
_this.hasValue = false;
|
_this.add(scheduler.schedule(dispatchNotification, period, { subscriber: _this, period: period }));
|
return _this;
|
}
|
SampleTimeSubscriber.prototype._next = function (value) {
|
this.lastValue = value;
|
this.hasValue = true;
|
};
|
SampleTimeSubscriber.prototype.notifyNext = function () {
|
if (this.hasValue) {
|
this.hasValue = false;
|
this.destination.next(this.lastValue);
|
}
|
};
|
return SampleTimeSubscriber;
|
}(Subscriber));
|
function dispatchNotification(state) {
|
var subscriber = state.subscriber, period = state.period;
|
subscriber.notifyNext();
|
this.schedule(state, period);
|
}
|
//# sourceMappingURL=sampleTime.js.map
|
