.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/retry.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 function retry(count) {
  18     if (count === void 0) { count = -1; }
  19     return function (source) { return source.lift(new RetryOperator(count, source)); };
  20 }
  21 exports.retry = retry;
  22 var RetryOperator = (function () {
  23     function RetryOperator(count, source) {
  24         this.count = count;
  25         this.source = source;
  26     }
  27     RetryOperator.prototype.call = function (subscriber, source) {
  28         return source.subscribe(new RetrySubscriber(subscriber, this.count, this.source));
  29     };
  30     return RetryOperator;
  31 }());
  32 var RetrySubscriber = (function (_super) {
  33     __extends(RetrySubscriber, _super);
  34     function RetrySubscriber(destination, count, source) {
  35         var _this = _super.call(this, destination) || this;
  36         _this.count = count;
  37         _this.source = source;
  38         return _this;
  39     }
  40     RetrySubscriber.prototype.error = function (err) {
  41         if (!this.isStopped) {
  42             var _a = this, source = _a.source, count = _a.count;
  43             if (count === 0) {
  44                 return _super.prototype.error.call(this, err);
  45             }
  46             else if (count > -1) {
  47                 this.count = count - 1;
  48             }
  49             source.subscribe(this._unsubscribeAndRecycle());
  50         }
  51     };
  52     return RetrySubscriber;
  53 }(Subscriber_1.Subscriber));
  54 //# sourceMappingURL=retry.js.map