- constructor(destination: Subscriber<T>, keySelector: (value: T) => K, flushes: Observable<any>);
- notifyNext(outerValue: T, innerValue: T, outerIndex: number, innerIndex: number, innerSub: InnerSubscriber<T, T>): void;
- notifyError(error: any, innerSub: InnerSubscriber<T, T>): void;
+ constructor(destination: Subscriber<T>, keySelector?: (value: T) => K, flushes?: Observable<any>);
+ notifyNext(): void;
+ notifyError(error: any): void;