import { Observable, OperatorFunction } from 'rxjs';
import { Subscription } from './interface';
/**
 *  @category Error
 *  @description Error that indicates an unsupported event being passed or used
 */
export declare class UnsupportedEventError extends Error {
    message: string;
    name: string;
    constructor(message: string);
}
export declare class ObservableSubscription<T> implements Subscription<T> {
    private shouldRetry;
    private operatorFunction;
    private errorListeners;
    private messageListeners;
    private closeListeners;
    private completed$;
    constructor(obs: Observable<T>, shouldRetry?: boolean, operatorFunction?: OperatorFunction<T, T>);
    private call;
    private remove;
    on(type: 'error', cb: (error: Error) => void): void;
    on(type: 'data', cb: (data: T) => void): void;
    on(type: 'close', cb: () => void): void;
    off(type: 'error', cb: (error: Error) => void): void;
    off(type: 'data', cb: (data: T) => void): void;
    off(type: 'close', cb: () => void): void;
    close(): void;
}