Giant blob of minor changes
[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / internal / operators / distinct.d.ts
index 3356046f219008fb697f2e795dfb155d682615a7..c79b577e94be2165ac6f5edf855d7324ef9c213e 100644 (file)
@@ -1,8 +1,7 @@
 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.
  *
@@ -67,12 +66,12 @@ export declare function distinct<T, K>(keySelector?: (value: T) => K, flushes?:
  * @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;