X-Git-Url: https://git.josue.xyz/?p=dotfiles%2F.git;a=blobdiff_plain;f=.config%2Fcoc%2Fextensions%2Fnode_modules%2Fcoc-prettier%2Fnode_modules%2Frxjs%2Finternal%2Foperators%2Fexpand.d.ts;h=c2305d2e6c7560946f19f48d246bca15b1abc428;hp=9164357fb4858c5e303833b7c9b1df4175799f96;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/expand.d.ts b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/expand.d.ts index 9164357f..c2305d2e 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/expand.d.ts +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/expand.d.ts @@ -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(project: (value: T, index: number) => ObservableInput, concurrent?: number, scheduler?: SchedulerLike): OperatorFunction; export declare function expand(project: (value: T, index: number) => ObservableInput, concurrent?: number, scheduler?: SchedulerLike): MonoTypeOperatorFunction; export declare class ExpandOperator implements Operator { private project; private concurrent; - private scheduler; - constructor(project: (value: T, index: number) => ObservableInput, concurrent: number, scheduler: SchedulerLike); + private scheduler?; + constructor(project: (value: T, index: number) => ObservableInput, concurrent: number, scheduler?: SchedulerLike); call(subscriber: Subscriber, source: any): any; } /** @@ -18,19 +16,19 @@ export declare class ExpandOperator implements Operator { * @ignore * @extends {Ignored} */ -export declare class ExpandSubscriber extends OuterSubscriber { +export declare class ExpandSubscriber extends SimpleOuterSubscriber { private project; private concurrent; - private scheduler; + private scheduler?; private index; private active; private hasCompleted; - private buffer; - constructor(destination: Subscriber, project: (value: T, index: number) => ObservableInput, concurrent: number, scheduler: SchedulerLike); + private buffer?; + constructor(destination: Subscriber, project: (value: T, index: number) => ObservableInput, 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): void; - notifyComplete(innerSub: Subscription): void; + notifyNext(innerValue: R): void; + notifyComplete(): void; }