Giant blob of minor changes
[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / internal / operators / expand.d.ts
index 9164357fb4858c5e303833b7c9b1df4175799f96..c2305d2e6c7560946f19f48d246bca15b1abc428 100644 (file)
@@ -1,16 +1,14 @@
 import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
-import { Subscription } from '../Subscription';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
 import { MonoTypeOperatorFunction, OperatorFunction, ObservableInput, SchedulerLike } from '../types';
+import { SimpleOuterSubscriber } from '../innerSubscribe';
 export declare function expand<T, R>(project: (value: T, index: number) => ObservableInput<R>, concurrent?: number, scheduler?: SchedulerLike): OperatorFunction<T, R>;
 export declare function expand<T>(project: (value: T, index: number) => ObservableInput<T>, concurrent?: number, scheduler?: SchedulerLike): MonoTypeOperatorFunction<T>;
 export declare class ExpandOperator<T, R> implements Operator<T, R> {
     private project;
     private concurrent;
-    private scheduler;
-    constructor(project: (value: T, index: number) => ObservableInput<R>, concurrent: number, scheduler: SchedulerLike);
+    private scheduler?;
+    constructor(project: (value: T, index: number) => ObservableInput<R>, concurrent: number, scheduler?: SchedulerLike);
     call(subscriber: Subscriber<R>, source: any): any;
 }
 /**
@@ -18,19 +16,19 @@ export declare class ExpandOperator<T, R> implements Operator<T, R> {
  * @ignore
  * @extends {Ignored}
  */
-export declare class ExpandSubscriber<T, R> extends OuterSubscriber<T, R> {
+export declare class ExpandSubscriber<T, R> extends SimpleOuterSubscriber<T, R> {
     private project;
     private concurrent;
-    private scheduler;
+    private scheduler?;
     private index;
     private active;
     private hasCompleted;
-    private buffer;
-    constructor(destination: Subscriber<R>, project: (value: T, index: number) => ObservableInput<R>, concurrent: number, scheduler: SchedulerLike);
+    private buffer?;
+    constructor(destination: Subscriber<R>, project: (value: T, index: number) => ObservableInput<R>, concurrent: number, scheduler?: SchedulerLike);
     private static dispatch;
     protected _next(value: any): void;
     private subscribeToProjection;
     protected _complete(): void;
-    notifyNext(outerValue: T, innerValue: R, outerIndex: number, innerIndex: number, innerSub: InnerSubscriber<T, R>): void;
-    notifyComplete(innerSub: Subscription): void;
+    notifyNext(innerValue: R): void;
+    notifyComplete(): void;
 }