import { Observable } from "rxjs";
import HttpApi from "../../clients/http";
import { ContractEvent } from "./events";
/**
 * Produces a stream of events from a contract
 */
export declare class ContractEventStream {
    private httpApi;
    private contractAddress;
    private contractObj;
    constructor(contractAddress: string, httpApi: HttpApi);
    private getContract;
    /**
     * Retrieve events
     *
     * @param latestTimestamp
     */
    getEvents(latestTimestamp?: number): Observable<ContractEvent>;
    listenToEvents(fromTimestamp?: number): Observable<ContractEvent>;
}