import { type Noop, noop } from '../../utils/noop';
export type TeardownLogic = Unsubscribable | Noop | void;
export type UnaryFunction<TSource = any, TReturn = any> = (source: TSource) => TReturn;
export type MonoTypeOperatorFunction<TValue, TError> = OperatorFunction<TValue, TError, TValue, TError>;
export type OperatorFunction<TValueBefore = any, TErrorBefore = any, TValueAfter = any, TErrorAfter = any> = UnaryFunction<Subscribable<TValueBefore, TErrorBefore>, Subscribable<TValueAfter, TErrorAfter>>;
export type Observer<TValue = any, TError = any> = {
    next: (value: TValue) => void;
    error: (err: TError) => void;
    complete: () => void;
};
export type Unsubscribable = {
    unsubscribe(): void;
};
export type InferObservableValue<TObservable> = TObservable extends Observable<infer TValue, unknown> ? TValue : never;
export declare function isObservable(x: unknown): x is Observable<unknown, unknown>;
export declare function pipeReducer(previousValue: any, next: UnaryFunction): any;
export declare function promisifyObservable<T>(observable: Observable<T>): {
    promise: Promise<T>;
    abort: typeof noop;
};
export declare class ObservableAbortError extends Error {
    constructor(message?: string);
}
export declare class Subscribable<TValue = any, TError = any> {
    onSubscribe: (observer: Observer<TValue, TError>) => TeardownLogic;
    constructor(onSubscribe: (observer: Observer<TValue, TError>) => TeardownLogic);
    subscribe(observer?: Partial<Observer<TValue, TError>>): Unsubscribable;
}
export declare class Observable<TValue = any, TError = any> extends Subscribable<TValue, TError> {
    constructor(onSubscribe: (observer: Observer<TValue, TError>) => TeardownLogic);
    pipe(): Observable<TValue, TError>;
    pipe<TValue1, TError1>(op1: OperatorFunction<TValue, TError, TValue1, TError1>): Observable<TValue1, TError1>;
    pipe<TValue1, TError1, TValue2, TError2>(op1: OperatorFunction<TValue, TError, TValue1, TError1>, op2: OperatorFunction<TValue1, TError1, TValue2, TError2>): Observable<TValue2, TError2>;
    pipe<TValue1, TError1, TValue2, TError2, TValue3, TError3>(op1: OperatorFunction<TValue, TError, TValue1, TError1>, op2: OperatorFunction<TValue1, TError1, TValue2, TError2>, op3: OperatorFunction<TValue2, TError2, TValue3, TError3>): Observable<TValue3, TError3>;
    pipe<TValue1, TError1, TValue2, TError2, TValue3, TError3, TValue4, TError4>(op1: OperatorFunction<TValue, TError, TValue1, TError1>, op2: OperatorFunction<TValue1, TError1, TValue2, TError2>, op3: OperatorFunction<TValue2, TError2, TValue3, TError3>, op4: OperatorFunction<TValue3, TError3, TValue4, TError4>): Observable<TValue4, TError4>;
    pipe<TValue1, TError1, TValue2, TError2, TValue3, TError3, TValue4, TError4, TValue5, TError5>(op1: OperatorFunction<TValue, TError, TValue1, TError1>, op2: OperatorFunction<TValue1, TError1, TValue2, TError2>, op3: OperatorFunction<TValue2, TError2, TValue3, TError3>, op4: OperatorFunction<TValue3, TError3, TValue4, TError4>, op5: OperatorFunction<TValue4, TError4, TValue5, TError5>): Observable<TValue5, TError5>;
}
//# sourceMappingURL=observable.d.ts.map