import { fromArray } from './fromArray';
const NONE = {};
export function combineLatest(...observables) {
- let resultSelector = null;
- let scheduler = null;
+ let resultSelector = undefined;
+ let scheduler = undefined;
if (isScheduler(observables[observables.length - 1])) {
scheduler = observables.pop();
}
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));
}
}
}
this.destination.complete();
}
}
- notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
+ notifyNext(_outerValue, innerValue, outerIndex) {
const values = this.values;
const oldVal = values[outerIndex];
const toRespond = !this.toRespond