import { StreamPricesResponse } from '@injectivelabs/exchange-api/injective_oracle_rpc_pb';
import { InjectiveOracleRPCClient } from '@injectivelabs/exchange-api/injective_oracle_rpc_pb_service';
import { StreamOperation } from '@injectivelabs/ts-types';
import { StreamStatusResponse } from '../../types';
export declare type PricesStreamCallback = ({ operation, price, timestamp, }: {
    price: string;
    operation: StreamOperation;
    timestamp: number;
}) => void;
export declare class PricesStream {
    protected client: InjectiveOracleRPCClient;
    protected endpoint: string;
    constructor(endpoint: string);
    start({ oracleType, baseSymbol, quoteSymbol, callback, onEndCallback, onStatusCallback, }: {
        oracleType: string;
        baseSymbol: string;
        quoteSymbol: string;
        callback: PricesStreamCallback;
        onEndCallback?: (status?: StreamStatusResponse) => void;
        onStatusCallback?: (status: StreamStatusResponse) => void;
    }): import("@injectivelabs/exchange-api/injective_oracle_rpc_pb_service").ResponseStream<StreamPricesResponse>;
}
//# sourceMappingURL=PricesStream.d.ts.map