@reactivex/rxjs/dist/typings/internal/innerSubscribe.d.ts

/** @prettier */
import { Subscription } from './Subscription';
import { Subscriber } from './Subscriber';
interface SimpleOuterSubscriberLike<T> {
    /**
     * A handler for inner next notifications from the inner subscription
     * @param innerValue the value nexted by the inner producer
     */
    notifyNext(innerValue: T): void;
    /**
     * A handler for inner error notifications from the inner subscription
     * @param err the error from the inner producer
     */
    notifyError(err: any): void;
    /**
     * A handler for inner complete notifications from the inner subscription.
     */
    notifyComplete(): void;
}
export declare class SimpleInnerSubscriber<T> extends Subscriber<T> {
    private parent;
    constructor(parent: SimpleOuterSubscriberLike<any>);
    protected _next(value: T): void;
    protected _error(error: any): void;
    protected _complete(): void;
}
export declare class ComplexInnerSubscriber<T, R> extends Subscriber<R> {
    private parent;
    outerValue: T;
    outerIndex: number;
    constructor(parent: ComplexOuterSubscriber<T, R>, outerValue: T, outerIndex: number);
    protected _next(value: R): void;
    protected _error(error: any): void;
    protected _complete(): void;
}
export declare class SimpleOuterSubscriber<T, R> extends Subscriber<T> implements SimpleOuterSubscriberLike<R> {
    notifyNext(innerValue: R): void;
    notifyError(err: any): void;
    notifyComplete(): void;
}
/**
 * DO NOT USE (formerly "OuterSubscriber")
 * TODO: We want to refactor this and remove it. It is retaining values it shouldn't for long
 * periods of time.
 */
export declare class ComplexOuterSubscriber<T, R> extends Subscriber<T> {
    /**
     * @param _outerValue Used by: bufferToggle, delayWhen, windowToggle
     * @param innerValue Used by: subclass default, combineLatest, race, bufferToggle, windowToggle, withLatestFrom
     * @param _outerIndex Used by: combineLatest, race, withLatestFrom
     * @param _innerSub Used by: delayWhen
     */
    notifyNext(_outerValue: T, innerValue: R, _outerIndex: number, _innerSub: ComplexInnerSubscriber<T, R>): void;
    notifyError(error: any): void;
    /**
     * @param _innerSub Used by: race, bufferToggle, delayWhen, windowToggle, windowWhen
     */
    notifyComplete(_innerSub: ComplexInnerSubscriber<T, R>): void;
}
export declare function innerSubscribe(result: any, innerSubscriber: Subscriber<any>): Subscription | undefined;
export {};