import { TxCallback } from './tx-callback';
import { TxTask } from './tx-task';
import { TxSubscribeOptions } from './tx-subscribe-options';
export declare class TxUnSubscribe<T> {
    from: TxSubscribe<T>;
    index: number;
    constructor(from: TxSubscribe<T>, index: number);
    unsubscribe(): void;
    readonly subscribe: TxSubscribe<T>;
}
export declare class TxSubscribe<T> {
    dataCB: TxCallback<T>[];
    errorCB: TxCallback<T>[];
    completeCB: TxCallback<T>[];
    from: T;
    limit: number;
    name: string;
    /**
     *
     * @param from - object that use this subscribe
     * @param limit - limit the number of subscribers, 0 => unlimited
     */
    constructor(from?: T, limit?: number);
    subscribe(dataCB: TxCallback<T>, errorCB?: TxCallback<T>, completeCB?: (any?: any) => void): TxUnSubscribe<T>;
    next(data: TxTask<any>, options?: TxSubscribeOptions): void;
    error(error: TxTask<any>, options?: TxSubscribeOptions): void;
    unsubscribe(index?: number): void;
    setName(name: string): void;
    getName(): string;
    setFrom(from: T): void;
    /**
     * return if nuber of subscribes in reach to its limit
     */
    private isLimit;
    getSubscribesLength(): number[];
}