import { Subscription } from './subscription';
/** Symbol.observable addition */
declare global {
    interface SymbolConstructor {
        readonly observable: symbol;
    }
}
declare let symbolObservable: any;
export { symbolObservable };
export interface NextObserver<T> {
    next: (value: T) => void;
    error?: (err: any) => void;
    complete?: () => void;
}
export interface ErrorObserver<T> {
    next?: (value: T) => void;
    error: (err: any) => void;
    complete?: () => void;
}
export interface CompletionObserver<T> {
    next?: (value: T) => void;
    error?: (err: any) => void;
    complete: () => void;
}
export declare type PartialObserver<T> = NextObserver<T> | ErrorObserver<T> | CompletionObserver<T>;
export interface NextAsyncObserver<T> {
    next: (value: T) => void | Promise<void>;
    error?: (err: any) => void | Promise<void>;
    complete?: () => void | Promise<void>;
}
export interface ErrorAsyncObserver<T> {
    next?: (value: T) => void | Promise<void>;
    error: (err: any) => void | Promise<void>;
    complete?: () => void | Promise<void>;
}
export interface CompletionAsyncObserver<T> {
    next?: (value: T) => void | Promise<void>;
    error?: (err: any) => void | Promise<void>;
    complete: () => void | Promise<void>;
}
export declare type PartialAsyncObserver<T> = NextAsyncObserver<T> | ErrorAsyncObserver<T> | CompletionAsyncObserver<T>;
export interface Observer<T> {
    closed?: boolean;
    next: (value: T) => void;
    error: (err: any) => void;
    complete: () => void;
}
export interface Observable<T> {
    [Symbol.observable]: () => Observable<T>;
    subscribe: (observerOrNext?: PartialObserver<T> | ((value: T) => void), error?: (err: any) => void, complete?: () => void) => Subscription;
}