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
/
window.ts
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/window.ts
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/window.ts
index f373dbc3997e5d4ed6183177755df8ce7d38512c..48390a3218231f9c2f8654f9f3ee4255ad6a54d8 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/window.ts
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/window.ts
@@
-2,10
+2,8
@@
import { Observable } from '../Observable';
import { OperatorFunction } from '../types';
import { Subject } from '../Subject';
import { Subscriber } from '../Subscriber';
import { OperatorFunction } from '../types';
import { Subject } from '../Subject';
import { Subscriber } from '../Subscriber';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
import { Operator } from '../Operator';
import { Operator } from '../Operator';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
/**
* Branch out the source Observable values as a nested Observable whenever
/**
* Branch out the source Observable values as a nested Observable whenever
@@
-65,7
+63,7
@@
class WindowOperator<T> implements Operator<T, Observable<T>> {
const windowSubscriber = new WindowSubscriber(subscriber);
const sourceSubscription = source.subscribe(windowSubscriber);
if (!sourceSubscription.closed) {
const windowSubscriber = new WindowSubscriber(subscriber);
const sourceSubscription = source.subscribe(windowSubscriber);
if (!sourceSubscription.closed) {
- windowSubscriber.add(
subscribeToResult(windowSubscriber, this.windowBoundaries
));
+ windowSubscriber.add(
innerSubscribe(this.windowBoundaries, new SimpleInnerSubscriber(windowSubscriber)
));
}
return sourceSubscription;
}
}
return sourceSubscription;
}
@@
-76,7
+74,7
@@
class WindowOperator<T> implements Operator<T, Observable<T>> {
* @ignore
* @extends {Ignored}
*/
* @ignore
* @extends {Ignored}
*/
-class WindowSubscriber<T> extends OuterSubscriber<T, any> {
+class WindowSubscriber<T> extends
Simple
OuterSubscriber<T, any> {
private window: Subject<T> = new Subject<T>();
private window: Subject<T> = new Subject<T>();
@@
-85,17
+83,15
@@
class WindowSubscriber<T> extends OuterSubscriber<T, any> {
destination.next(this.window);
}
destination.next(this.window);
}
- notifyNext(outerValue: T, innerValue: any,
- outerIndex: number, innerIndex: number,
- innerSub: InnerSubscriber<T, any>): void {
+ notifyNext(): void {
this.openWindow();
}
this.openWindow();
}
- notifyError(error: any
, innerSub: InnerSubscriber<T, any>
): void {
+ notifyError(error: any): void {
this._error(error);
}
this._error(error);
}
- notifyComplete(
innerSub: InnerSubscriber<T, any>
): void {
+ notifyComplete(): void {
this._complete();
}
this._complete();
}
@@
-105,17
+101,17
@@
class WindowSubscriber<T> extends OuterSubscriber<T, any> {
protected _error(err: any): void {
this.window.error(err);
protected _error(err: any): void {
this.window.error(err);
- this.destination.error(err);
+ this.destination.error
!
(err);
}
protected _complete(): void {
this.window.complete();
}
protected _complete(): void {
this.window.complete();
- this.destination.complete();
+ this.destination.complete
!
();
}
/** @deprecated This is an internal implementation detail, do not use. */
_unsubscribe() {
}
/** @deprecated This is an internal implementation detail, do not use. */
_unsubscribe() {
- this.window = null;
+ this.window = null
!
;
}
private openWindow(): void {
}
private openWindow(): void {
@@
-125,6
+121,6
@@
class WindowSubscriber<T> extends OuterSubscriber<T, any> {
}
const destination = this.destination;
const newWindow = this.window = new Subject<T>();
}
const destination = this.destination;
const newWindow = this.window = new Subject<T>();
- destination.next(newWindow);
+ destination.next
!
(newWindow);
}
}
}
}