import { SubjectStream } from 'dequanto/class/SubjectStream';
import { TEth } from 'dequanto/models/TEth';
import { TTransport } from './transports/ITransport';
export declare class RpcSubscription<T> extends SubjectStream<T> implements TTransport.Subscription<T> {
    id: TTransport.SubscriptionId;
    transport: TTransport.Transport;
    private _emitter;
    constructor(id: TTransport.SubscriptionId, transport: TTransport.Transport, mapper?: (value: any) => T);
    map(mapper: (x: T) => any): RpcSubscription<T>;
    unsubscribe(cb?: Function): Promise<boolean>;
    static createMapping<T>(subscription: TTransport.Subscription<any>, transport: TTransport.Transport, mapper: (x: any) => any): RpcSubscription<T>;
}
export type RpcLogFilterOptions = {
    address?: TEth.Address | TEth.Address[];
    topics?: TEth.Hex[];
};