import type { TAbiItem } from '../types/TAbi';
import { TAddress } from '../models/TAddress';
import { TEth } from '../models/TEth';
import { RpcSubscription } from '../rpc/RpcSubscription';
export interface TClientEventsStreamData<T extends any[] = any[]> {
    name: string;
    event: TEth.Log;
    arguments: T;
}
export declare class ClientEventsStream<T extends TClientEventsStreamData<unknown[]> = any> {
    address: TAddress;
    private abi;
    private streams;
    private innerStream;
    constructor(address: TAddress, eventAbi: TAbiItem | TAbiItem[], stream?: RpcSubscription<TEth.Log>);
    fromSubscription(web3Subscription: RpcSubscription<TEth.Log>): void;
    subscribe(cb: (x: T) => void, onError?: (x: Error | any) => void): import("../class/Subscription").Subscription;
    onData(cb: (event: TClientEventsStreamData) => void): this;
    onConnected(cb: any): this;
    error(error: Error): void;
    private onErrorInner;
    private onDataInner;
    private onConnectedInner;
}