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

   1 /** PURE_IMPORTS_START tslib,_Subject,_OuterSubscriber,_util_subscribeToResult PURE_IMPORTS_END */
   2 import * as tslib_1 from "tslib";
   3 import { Subject } from '../Subject';
   4 import { OuterSubscriber } from '../OuterSubscriber';
   5 import { subscribeToResult } from '../util/subscribeToResult';
   6 export function window(windowBoundaries) {
   7     return function windowOperatorFunction(source) {
   8         return source.lift(new WindowOperator(windowBoundaries));
   9     };
  10 }
  11 var WindowOperator = /*@__PURE__*/ (function () {
  12     function WindowOperator(windowBoundaries) {
  13         this.windowBoundaries = windowBoundaries;
  14     }
  15     WindowOperator.prototype.call = function (subscriber, source) {
  16         var windowSubscriber = new WindowSubscriber(subscriber);
  17         var sourceSubscription = source.subscribe(windowSubscriber);
  18         if (!sourceSubscription.closed) {
  19             windowSubscriber.add(subscribeToResult(windowSubscriber, this.windowBoundaries));
  20         }
  21         return sourceSubscription;
  22     };
  23     return WindowOperator;
  24 }());
  25 var WindowSubscriber = /*@__PURE__*/ (function (_super) {
  26     tslib_1.__extends(WindowSubscriber, _super);
  27     function WindowSubscriber(destination) {
  28         var _this = _super.call(this, destination) || this;
  29         _this.window = new Subject();
  30         destination.next(_this.window);
  31         return _this;
  32     }
  33     WindowSubscriber.prototype.notifyNext = function (outerValue, innerValue, outerIndex, innerIndex, innerSub) {
  34         this.openWindow();
  35     };
  36     WindowSubscriber.prototype.notifyError = function (error, innerSub) {
  37         this._error(error);
  38     };
  39     WindowSubscriber.prototype.notifyComplete = function (innerSub) {
  40         this._complete();
  41     };
  42     WindowSubscriber.prototype._next = function (value) {
  43         this.window.next(value);
  44     };
  45     WindowSubscriber.prototype._error = function (err) {
  46         this.window.error(err);
  47         this.destination.error(err);
  48     };
  49     WindowSubscriber.prototype._complete = function () {
  50         this.window.complete();
  51         this.destination.complete();
  52     };
  53     WindowSubscriber.prototype._unsubscribe = function () {
  54         this.window = null;
  55     };
  56     WindowSubscriber.prototype.openWindow = function () {
  57         var prevWindow = this.window;
  58         if (prevWindow) {
  59             prevWindow.complete();
  60         }
  61         var destination = this.destination;
  62         var newWindow = this.window = new Subject();
  63         destination.next(newWindow);
  64     };
  65     return WindowSubscriber;
  66 }(OuterSubscriber));
  67 //# sourceMappingURL=window.js.map