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
/
observable
/
combineLatest.ts
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/observable/combineLatest.ts
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/observable/combineLatest.ts
index ce093c9c20da88eb7cd5876712f9c567d04236d9..ac5e6ea08d6af39c0a4965fe129f7ad25b1e20f3 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/observable/combineLatest.ts
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/observable/combineLatest.ts
@@
-226,8
+226,8
@@
export function combineLatest<R>(...observables: Array<ObservableInput<any> | ((
export function combineLatest<O extends ObservableInput<any>, R>(
...observables: (O | ((...values: ObservedValueOf<O>[]) => R) | SchedulerLike)[]
): Observable<R> {
export function combineLatest<O extends ObservableInput<any>, R>(
...observables: (O | ((...values: ObservedValueOf<O>[]) => R) | SchedulerLike)[]
): Observable<R> {
- let resultSelector: (
...values: Array<any>) => R = null
;
- let scheduler: SchedulerLike
= null
;
+ let resultSelector: (
(...values: Array<any>) => R) | undefined = undefined
;
+ let scheduler: SchedulerLike
|undefined = undefined
;
if (isScheduler(observables[observables.length - 1])) {
scheduler = observables.pop() as SchedulerLike;
if (isScheduler(observables[observables.length - 1])) {
scheduler = observables.pop() as SchedulerLike;
@@
-243,7
+243,7
@@
export function combineLatest<O extends ObservableInput<any>, R>(
observables = observables[0] as any;
}
observables = observables[0] as any;
}
- return fromArray(observables, scheduler).lift(new CombineLatestOperator
<ObservedValueOf<O>, R>
(resultSelector));
+ return fromArray(observables, scheduler).lift(new CombineLatestOperator(resultSelector));
}
export class CombineLatestOperator<T, R> implements Operator<T, R> {
}
export class CombineLatestOperator<T, R> implements Operator<T, R> {
@@
-264,7
+264,7
@@
export class CombineLatestSubscriber<T, R> extends OuterSubscriber<T, R> {
private active: number = 0;
private values: any[] = [];
private observables: any[] = [];
private active: number = 0;
private values: any[] = [];
private observables: any[] = [];
- private toRespond: number;
+ private toRespond
?
: number;
constructor(destination: Subscriber<R>, private resultSelector?: (...values: Array<any>) => R) {
super(destination);
constructor(destination: Subscriber<R>, private resultSelector?: (...values: Array<any>) => R) {
super(destination);
@@
-279,26
+279,25
@@
export class CombineLatestSubscriber<T, R> extends OuterSubscriber<T, R> {
const observables = this.observables;
const len = observables.length;
if (len === 0) {
const observables = this.observables;
const len = observables.length;
if (len === 0) {
- this.destination.complete();
+ this.destination.complete
!
();
} else {
this.active = len;
this.toRespond = len;
for (let i = 0; i < len; i++) {
const observable = observables[i];
} else {
this.active = len;
this.toRespond = len;
for (let i = 0; i < len; i++) {
const observable = observables[i];
- this.add(subscribeToResult(this, observable,
observable
, i));
+ this.add(subscribeToResult(this, observable,
undefined
, i));
}
}
}
notifyComplete(unused: Subscriber<R>): void {
if ((this.active -= 1) === 0) {
}
}
}
notifyComplete(unused: Subscriber<R>): void {
if ((this.active -= 1) === 0) {
- this.destination.complete();
+ this.destination.complete
!
();
}
}
}
}
- notifyNext(outerValue: T, innerValue: R,
- outerIndex: number, innerIndex: number,
- innerSub: InnerSubscriber<T, R>): void {
+ notifyNext(_outerValue: T, innerValue: R,
+ outerIndex: number): void {
const values = this.values;
const oldVal = values[outerIndex];
const toRespond = !this.toRespond
const values = this.values;
const oldVal = values[outerIndex];
const toRespond = !this.toRespond
@@
-310,7
+309,7
@@
export class CombineLatestSubscriber<T, R> extends OuterSubscriber<T, R> {
if (this.resultSelector) {
this._tryResultSelector(values);
} else {
if (this.resultSelector) {
this._tryResultSelector(values);
} else {
- this.destination.next(values.slice());
+ this.destination.next
!
(values.slice());
}
}
}
}
}
}
@@
-318,11
+317,11
@@
export class CombineLatestSubscriber<T, R> extends OuterSubscriber<T, R> {
private _tryResultSelector(values: any[]) {
let result: any;
try {
private _tryResultSelector(values: any[]) {
let result: any;
try {
- result = this.resultSelector.apply(this, values);
+ result = this.resultSelector
!
.apply(this, values);
} catch (err) {
} catch (err) {
- this.destination.error(err);
+ this.destination.error
!
(err);
return;
}
return;
}
- this.destination.next(result);
+ this.destination.next
!
(result);
}
}
}
}