.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/sampleTime.js

   1 "use strict";
   2 var __extends = (this && this.__extends) || (function () {
   3     var extendStatics = function (d, b) {
   4         extendStatics = Object.setPrototypeOf ||
   5             ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
   6             function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
   7         return extendStatics(d, b);
   8     }
   9     return function (d, b) {
  10         extendStatics(d, b);
  11         function __() { this.constructor = d; }
  12         d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
  13     };
  14 })();
  15 Object.defineProperty(exports, "__esModule", { value: true });
  16 var Subscriber_1 = require("../Subscriber");
  17 var async_1 = require("../scheduler/async");
  18 function sampleTime(period, scheduler) {
  19     if (scheduler === void 0) { scheduler = async_1.async; }
  20     return function (source) { return source.lift(new SampleTimeOperator(period, scheduler)); };
  21 }
  22 exports.sampleTime = sampleTime;
  23 var SampleTimeOperator = (function () {
  24     function SampleTimeOperator(period, scheduler) {
  25         this.period = period;
  26         this.scheduler = scheduler;
  27     }
  28     SampleTimeOperator.prototype.call = function (subscriber, source) {
  29         return source.subscribe(new SampleTimeSubscriber(subscriber, this.period, this.scheduler));
  30     };
  31     return SampleTimeOperator;
  32 }());
  33 var SampleTimeSubscriber = (function (_super) {
  34     __extends(SampleTimeSubscriber, _super);
  35     function SampleTimeSubscriber(destination, period, scheduler) {
  36         var _this = _super.call(this, destination) || this;
  37         _this.period = period;
  38         _this.scheduler = scheduler;
  39         _this.hasValue = false;
  40         _this.add(scheduler.schedule(dispatchNotification, period, { subscriber: _this, period: period }));
  41         return _this;
  42     }
  43     SampleTimeSubscriber.prototype._next = function (value) {
  44         this.lastValue = value;
  45         this.hasValue = true;
  46     };
  47     SampleTimeSubscriber.prototype.notifyNext = function () {
  48         if (this.hasValue) {
  49             this.hasValue = false;
  50             this.destination.next(this.lastValue);
  51         }
  52     };
  53     return SampleTimeSubscriber;
  54 }(Subscriber_1.Subscriber));
  55 function dispatchNotification(state) {
  56     var subscriber = state.subscriber, period = state.period;
  57     subscriber.notifyNext();
  58     this.schedule(state, period);
  59 }
  60 //# sourceMappingURL=sampleTime.js.map