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
/
delayWhen.ts
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/delayWhen.ts
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/delayWhen.ts
index ce41541ce398a2f9aef7c9e88458cf7db846eb87..33cc44882b5b7060fd67dc318d3a918887930151 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/delayWhen.ts
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/delayWhen.ts
@@
-107,10
+107,10
@@
class DelayWhenSubscriber<T, R> extends OuterSubscriber<T, R> {
super(destination);
}
super(destination);
}
- notifyNext(outerValue: T, innerValue: any,
-
outerIndex: number,
innerIndex: number,
+ notifyNext(outerValue: T,
_
innerValue: any,
+
_outerIndex: number, _
innerIndex: number,
innerSub: InnerSubscriber<T, R>): void {
innerSub: InnerSubscriber<T, R>): void {
- this.destination.next(outerValue);
+ this.destination.next
!
(outerValue);
this.removeSubscription(innerSub);
this.tryComplete();
}
this.removeSubscription(innerSub);
this.tryComplete();
}
@@
-122,7
+122,7
@@
class DelayWhenSubscriber<T, R> extends OuterSubscriber<T, R> {
notifyComplete(innerSub: InnerSubscriber<T, R>): void {
const value = this.removeSubscription(innerSub);
if (value) {
notifyComplete(innerSub: InnerSubscriber<T, R>): void {
const value = this.removeSubscription(innerSub);
if (value) {
- this.destination.next(value);
+ this.destination.next
!
(value);
}
this.tryComplete();
}
}
this.tryComplete();
}
@@
-135,7
+135,7
@@
class DelayWhenSubscriber<T, R> extends OuterSubscriber<T, R> {
this.tryDelay(delayNotifier, value);
}
} catch (err) {
this.tryDelay(delayNotifier, value);
}
} catch (err) {
- this.destination.error(err);
+ this.destination.error
!
(err);
}
}
}
}
@@
-168,7
+168,7
@@
class DelayWhenSubscriber<T, R> extends OuterSubscriber<T, R> {
private tryComplete(): void {
if (this.completed && this.delayNotifierSubscriptions.length === 0) {
private tryComplete(): void {
if (this.completed && this.delayNotifierSubscriptions.length === 0) {
- this.destination.complete();
+ this.destination.complete
!
();
}
}
}
}
}
}