import HttpApi from "./index";
import { GetNowBlockJSON, TransactionJSON } from "./types";
import { Observable } from "rxjs";
import TransactionInfo from "../../blockchain/transaction/transactionInfo";
export default class HttpApiStreams {
    private httpApi;
    constructor(httpApi: HttpApi);
    getBlockTimer(): Observable<number>;
    /**
     * Retrieves the current block periodically
     */
    getBlockStream(): Observable<GetNowBlockJSON>;
    /**
     * Retrieve specifc block
     */
    getBlockNumberStream(blockNumber: number): Observable<GetNowBlockJSON>;
    /**
     * Retrieve transactions from the given block
     */
    getTransactionsFromBlock(): import("rxjs").OperatorFunction<any, {}>;
    /**
     * Filter the transactions by the given contract type
     */
    filterContractType(type: any): import("rxjs").MonoTypeOperatorFunction<any>;
    /**
     * Filter the stream by the given contract value
     *
     * @param func
     */
    filterContractValue(func: any): import("rxjs").MonoTypeOperatorFunction<any>;
    /**
     * Download transaction info from the given
     */
    getInfoFromTransactions(): import("rxjs").UnaryFunction<Observable<TransactionJSON>, Observable<TransactionInfo>>;
    /**
     * Retrieve events from the transactioninfo contract
     */
    getEventsFromContract(): import("rxjs").UnaryFunction<Observable<TransactionInfo>, Observable<{
        transaction: string;
        contract: string;
        name: string;
        index: number;
        result: {
            [key: string]: string;
        };
        resourceNode: string;
    }>>;
    /**
     * Reads events from the given contract addresses
     *
     * @param watchedContracts
     */
    readEventsFromContract(watchedContracts: string[]): Observable<{
        block: any;
        timestamp: any;
        transaction: string;
        contract: string;
        name: string;
        index: number;
        result: {
            [key: string]: string;
        };
        resourceNode: string;
    }>;
}