import { IAddFilter, IErrorCallback, IFilterSetup, IObserver, ISetup, IStream, ISubscribeGroup, ISubscribeObject, ISubscriptionLike } from "./Types";
import { SubscribeObject } from "./SubscribeObject";
import { FilterCollection } from "./FilterCollection";
export declare class Observable<T> implements IObserver<T>, IStream<T>, IAddFilter<T> {
    protected subs: ISubscribeObject<T>[];
    protected enabled: boolean;
    protected killed: boolean;
    protected process: boolean;
    protected trash: ISubscriptionLike[];
    protected filters: FilterCollection<T>;
    protected _value: T | null;
    constructor(value?: T | null);
    addFilter(errorHandler?: IErrorCallback): IFilterSetup<T>;
    disable(): void;
    enable(): void;
    get isEnable(): boolean;
    next(value: T): void;
    of(values: T[]): void;
    in<K extends string | number | symbol, V>(obj: Record<K, V>): void;
    private clearTrash;
    unSubscribe(listener: ISubscriptionLike): void;
    destroy(): void;
    unsubscribeAll(): void;
    protected clearDebounceTimers(): void;
    getValue(): T | undefined;
    size(): number;
    subscribe(observer: ISubscribeGroup<T>, errorHandler?: IErrorCallback): ISubscriptionLike;
    protected addObserver(subscribeObject: SubscribeObject<T>, observer: ISubscribeGroup<T>, errorHandler?: IErrorCallback): void;
    protected isListener(listener: ISubscribeGroup<T>): boolean;
    pipe(): ISetup<T>;
    get isDestroyed(): boolean;
}