projects
/
dotfiles
/
.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Giant blob of minor changes
[dotfiles/.git]
/
.config
/
coc
/
extensions
/
node_modules
/
coc-prettier
/
node_modules
/
rxjs
/
internal
/
operators
/
retryWhen.js
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/retryWhen.js
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/retryWhen.js
index b543dd141abe9b193b2b4b3ac8367d6b894f023f..9c0b48864cde58b41fa188ca00dd3cf7f369889c 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/retryWhen.js
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/retryWhen.js
@@
-14,8
+14,7
@@
var __extends = (this && this.__extends) || (function () {
})();
Object.defineProperty(exports, "__esModule", { value: true });
var Subject_1 = require("../Subject");
})();
Object.defineProperty(exports, "__esModule", { value: true });
var Subject_1 = require("../Subject");
-var OuterSubscriber_1 = require("../OuterSubscriber");
-var subscribeToResult_1 = require("../util/subscribeToResult");
+var innerSubscribe_1 = require("../innerSubscribe");
function retryWhen(notifier) {
return function (source) { return source.lift(new RetryWhenOperator(notifier, source)); };
}
function retryWhen(notifier) {
return function (source) { return source.lift(new RetryWhenOperator(notifier, source)); };
}
@@
-52,11
+51,11
@@
var RetryWhenSubscriber = (function (_super) {
catch (e) {
return _super.prototype.error.call(this, e);
}
catch (e) {
return _super.prototype.error.call(this, e);
}
- retriesSubscription =
subscribeToResult_1.subscribeToResult(this, retries
);
+ retriesSubscription =
innerSubscribe_1.innerSubscribe(retries, new innerSubscribe_1.SimpleInnerSubscriber(this)
);
}
else {
}
else {
- this.errors =
null
;
- this.retriesSubscription =
null
;
+ this.errors =
undefined
;
+ this.retriesSubscription =
undefined
;
}
this._unsubscribeAndRecycle();
this.errors = errors;
}
this._unsubscribeAndRecycle();
this.errors = errors;
@@
-69,15
+68,15
@@
var RetryWhenSubscriber = (function (_super) {
var _a = this, errors = _a.errors, retriesSubscription = _a.retriesSubscription;
if (errors) {
errors.unsubscribe();
var _a = this, errors = _a.errors, retriesSubscription = _a.retriesSubscription;
if (errors) {
errors.unsubscribe();
- this.errors =
null
;
+ this.errors =
undefined
;
}
if (retriesSubscription) {
retriesSubscription.unsubscribe();
}
if (retriesSubscription) {
retriesSubscription.unsubscribe();
- this.retriesSubscription =
null
;
+ this.retriesSubscription =
undefined
;
}
}
- this.retries =
null
;
+ this.retries =
undefined
;
};
};
- RetryWhenSubscriber.prototype.notifyNext = function (
outerValue, innerValue, outerIndex, innerIndex, innerSub
) {
+ RetryWhenSubscriber.prototype.notifyNext = function () {
var _unsubscribe = this._unsubscribe;
this._unsubscribe = null;
this._unsubscribeAndRecycle();
var _unsubscribe = this._unsubscribe;
this._unsubscribe = null;
this._unsubscribeAndRecycle();
@@
-85,5
+84,5
@@
var RetryWhenSubscriber = (function (_super) {
this.source.subscribe(this);
};
return RetryWhenSubscriber;
this.source.subscribe(this);
};
return RetryWhenSubscriber;
-}(
OuterSubscriber_1.
OuterSubscriber));
+}(
innerSubscribe_1.Simple
OuterSubscriber));
//# sourceMappingURL=retryWhen.js.map
\ No newline at end of file
//# sourceMappingURL=retryWhen.js.map
\ No newline at end of file