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
/
windowWhen.ts
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/windowWhen.ts
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/windowWhen.ts
index aa0cf2cf672826b7f565cb33c791ec6ebc062818..67e0b16b1c3e4b3cbb11c09e6437e56295e34bb6 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/windowWhen.ts
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/windowWhen.ts
@@
-74,8
+74,8
@@
class WindowOperator<T> implements Operator<T, Observable<T>> {
* @extends {Ignored}
*/
class WindowSubscriber<T> extends OuterSubscriber<T, any> {
* @extends {Ignored}
*/
class WindowSubscriber<T> extends OuterSubscriber<T, any> {
- private window: Subject<T>;
- private closingNotification: Subscription;
+ private window
?
: Subject<T>;
+ private closingNotification
?
: Subscription;
constructor(protected destination: Subscriber<Observable<T>>,
private closingSelector: () => Observable<any>) {
constructor(protected destination: Subscriber<Observable<T>>,
private closingSelector: () => Observable<any>) {
@@
-83,13
+83,13
@@
class WindowSubscriber<T> extends OuterSubscriber<T, any> {
this.openWindow();
}
this.openWindow();
}
- notifyNext(
outerValue: T,
innerValue: any,
-
outerIndex: number,
innerIndex: number,
+ notifyNext(
_outerValue: T, _
innerValue: any,
+
_outerIndex: number, _
innerIndex: number,
innerSub: InnerSubscriber<T, any>): void {
this.openWindow(innerSub);
}
innerSub: InnerSubscriber<T, any>): void {
this.openWindow(innerSub);
}
- notifyError(error: any
, innerSub: InnerSubscriber<T, any>
): void {
+ notifyError(error: any): void {
this._error(error);
}
this._error(error);
}
@@
-98,17
+98,17
@@
class WindowSubscriber<T> extends OuterSubscriber<T, any> {
}
protected _next(value: T): void {
}
protected _next(value: T): void {
- this.window.next(value);
+ this.window
!
.next(value);
}
protected _error(err: any): void {
}
protected _error(err: any): void {
- this.window.error(err);
+ this.window
!
.error(err);
this.destination.error(err);
this.unsubscribeClosingNotification();
}
protected _complete(): void {
this.destination.error(err);
this.unsubscribeClosingNotification();
}
protected _complete(): void {
- this.window.complete();
+ this.window
!
.complete();
this.destination.complete();
this.unsubscribeClosingNotification();
}
this.destination.complete();
this.unsubscribeClosingNotification();
}
@@
-119,7
+119,7
@@
class WindowSubscriber<T> extends OuterSubscriber<T, any> {
}
}
}
}
- private openWindow(innerSub: InnerSubscriber<T, any> = null): void {
+ private openWindow(innerSub: InnerSubscriber<T, any>
| null
= null): void {
if (innerSub) {
this.remove(innerSub);
innerSub.unsubscribe();
if (innerSub) {
this.remove(innerSub);
innerSub.unsubscribe();