import { Observable } from '../Observable';
import { Subscriber } from '../Subscriber';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
import { MonoTypeOperatorFunction } from '../types';
+import { SimpleOuterSubscriber } from '../innerSubscribe';
/**
* Returns an Observable that emits all items emitted by the source Observable that are distinct by comparison from previous items.
*
* @ignore
* @extends {Ignored}
*/
-export declare class DistinctSubscriber<T, K> extends OuterSubscriber<T, T> {
- private keySelector;
+export declare class DistinctSubscriber<T, K> extends SimpleOuterSubscriber<T, T> {
+ private keySelector?;
private values;
- 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;
protected _next(value: T): void;
private _useKeySelector;
private _finalizeNext;