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
/
_esm2015
/
internal
/
operators
/
retryWhen.js
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/retryWhen.js
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/retryWhen.js
index 87fef62c2de1705ddbdee4f69498b6f1ee2ef620..0f3aa2fbf76311235352f4fe5079c458cfe85f83 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/retryWhen.js
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/retryWhen.js
@@
-1,6
+1,5
@@
import { Subject } from '../Subject';
import { Subject } from '../Subject';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
export function retryWhen(notifier) {
return (source) => source.lift(new RetryWhenOperator(notifier, source));
}
export function retryWhen(notifier) {
return (source) => source.lift(new RetryWhenOperator(notifier, source));
}
@@
-13,7
+12,7
@@
class RetryWhenOperator {
return source.subscribe(new RetryWhenSubscriber(subscriber, this.notifier, this.source));
}
}
return source.subscribe(new RetryWhenSubscriber(subscriber, this.notifier, this.source));
}
}
-class RetryWhenSubscriber extends OuterSubscriber {
+class RetryWhenSubscriber extends
Simple
OuterSubscriber {
constructor(destination, notifier, source) {
super(destination);
this.notifier = notifier;
constructor(destination, notifier, source) {
super(destination);
this.notifier = notifier;
@@
-33,11
+32,11
@@
class RetryWhenSubscriber extends OuterSubscriber {
catch (e) {
return super.error(e);
}
catch (e) {
return super.error(e);
}
- retriesSubscription =
subscribeToResult(this, retries
);
+ retriesSubscription =
innerSubscribe(retries, new 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;
@@
-50,15
+49,15
@@
class RetryWhenSubscriber extends OuterSubscriber {
const { errors, retriesSubscription } = this;
if (errors) {
errors.unsubscribe();
const { errors, retriesSubscription } = this;
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
;
}
}
- notifyNext(
outerValue, innerValue, outerIndex, innerIndex, innerSub
) {
+ notifyNext() {
const { _unsubscribe } = this;
this._unsubscribe = null;
this._unsubscribeAndRecycle();
const { _unsubscribe } = this;
this._unsubscribe = null;
this._unsubscribeAndRecycle();