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
/
src
/
internal
/
operators
/
repeatWhen.ts
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/repeatWhen.ts
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/repeatWhen.ts
index ecdbe3112ef412fbf5cd745a713696158fc0fc57..744ec4b29bc784febea4c67ecea99bdf0ed1574f 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/repeatWhen.ts
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/repeatWhen.ts
@@
-4,11
+4,8
@@
import { Observable } from '../Observable';
import { Subject } from '../Subject';
import { Subscription } from '../Subscription';
import { Subject } from '../Subject';
import { Subscription } from '../Subscription';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
-
import { MonoTypeOperatorFunction, TeardownLogic } from '../types';
import { MonoTypeOperatorFunction, TeardownLogic } from '../types';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
/**
* Returns an Observable that mirrors the source Observable with the exception of a `complete`. If the source
/**
* Returns an Observable that mirrors the source Observable with the exception of a `complete`. If the source
@@
-58,11
+55,11
@@
class RepeatWhenOperator<T> implements Operator<T, T> {
* @ignore
* @extends {Ignored}
*/
* @ignore
* @extends {Ignored}
*/
-class RepeatWhenSubscriber<T, R> extends OuterSubscriber<T, R> {
+class RepeatWhenSubscriber<T, R> extends
Simple
OuterSubscriber<T, R> {
- private notifications: Subject<any>;
- private retries: Observable<any>;
- private retriesSubscription: Subscription;
+ private notifications
?
: Subject<any>;
+ private retries
?
: Observable<any>;
+ private retriesSubscription
?
: Subscription;
private sourceIsBeingSubscribedTo: boolean = true;
constructor(destination: Subscriber<R>,
private sourceIsBeingSubscribedTo: boolean = true;
constructor(destination: Subscriber<R>,
@@
-71,14
+68,12
@@
class RepeatWhenSubscriber<T, R> extends OuterSubscriber<T, R> {
super(destination);
}
super(destination);
}
- notifyNext(outerValue: T, innerValue: R,
- outerIndex: number, innerIndex: number,
- innerSub: InnerSubscriber<T, R>): void {
+ notifyNext(): void {
this.sourceIsBeingSubscribedTo = true;
this.source.subscribe(this);
}
this.sourceIsBeingSubscribedTo = true;
this.source.subscribe(this);
}
- notifyComplete(
innerSub: InnerSubscriber<T, R>
): void {
+ notifyComplete(): void {
if (this.sourceIsBeingSubscribedTo === false) {
return super.complete();
}
if (this.sourceIsBeingSubscribedTo === false) {
return super.complete();
}
@@
-96,7
+91,7
@@
class RepeatWhenSubscriber<T, R> extends OuterSubscriber<T, R> {
}
this._unsubscribeAndRecycle();
}
this._unsubscribeAndRecycle();
- this.notifications
.next(
);
+ this.notifications
!.next(undefined
);
}
}
}
}
@@
-105,20
+100,20
@@
class RepeatWhenSubscriber<T, R> extends OuterSubscriber<T, R> {
const { notifications, retriesSubscription } = this;
if (notifications) {
notifications.unsubscribe();
const { notifications, retriesSubscription } = this;
if (notifications) {
notifications.unsubscribe();
- this.notifications =
null
;
+ this.notifications =
undefined
;
}
if (retriesSubscription) {
retriesSubscription.unsubscribe();
}
if (retriesSubscription) {
retriesSubscription.unsubscribe();
- this.retriesSubscription =
null
;
+ this.retriesSubscription =
undefined
;
}
}
- this.retries =
null
;
+ this.retries =
undefined
;
}
/** @deprecated This is an internal implementation detail, do not use. */
_unsubscribeAndRecycle(): Subscriber<T> {
const { _unsubscribe } = this;
}
/** @deprecated This is an internal implementation detail, do not use. */
_unsubscribeAndRecycle(): Subscriber<T> {
const { _unsubscribe } = this;
- this._unsubscribe = null;
+ this._unsubscribe = null
!
;
super._unsubscribeAndRecycle();
this._unsubscribe = _unsubscribe;
super._unsubscribeAndRecycle();
this._unsubscribe = _unsubscribe;
@@
-135,6
+130,6
@@
class RepeatWhenSubscriber<T, R> extends OuterSubscriber<T, R> {
return super.complete();
}
this.retries = retries;
return super.complete();
}
this.retries = retries;
- this.retriesSubscription =
subscribeToResult(this, retries
);
+ this.retriesSubscription =
innerSubscribe(retries, new SimpleInnerSubscriber(this)
);
}
}
}
}