import { CallOptions } from 'nice-grpc';
import { DeepPartial, GetCandlesRequest_CandleSource, MarketDataRequest, MarketDataResponse, OrderBookType, SubscriptionInterval, TradeSourceType } from './generated/marketdata';
type MaybeClosableAsyncIterable<T> = AsyncIterable<T> & {
    return?: (value?: unknown) => Promise<unknown>;
};
type MarketDataStreamClient = {
    marketDataStream(request: AsyncIterable<DeepPartial<MarketDataRequest>>, options?: CallOptions): MaybeClosableAsyncIterable<MarketDataResponse>;
};
export type CreateMarketDataStreamControllerOptions = {
    callOptions?: CallOptions;
    closeGraceMs?: number;
};
export type MarketDataStreamController = {
    response: MaybeClosableAsyncIterable<MarketDataResponse>;
    send: (request: DeepPartial<MarketDataRequest>) => void;
    subscribeLastPrice: (instrumentId: string | string[]) => void;
    unsubscribeLastPrice: (instrumentId: string | string[]) => void;
    subscribeInfo: (instrumentId: string | string[]) => void;
    unsubscribeInfo: (instrumentId: string | string[]) => void;
    subscribeCandles: (instrumentId: string | string[], options?: {
        interval?: SubscriptionInterval;
        waitingClose?: boolean;
        candleSourceType?: GetCandlesRequest_CandleSource;
    }) => void;
    unsubscribeCandles: (instrumentId: string | string[], options?: {
        interval?: SubscriptionInterval;
        waitingClose?: boolean;
        candleSourceType?: GetCandlesRequest_CandleSource;
    }) => void;
    subscribeOrderBook: (instrumentId: string | string[], options?: {
        depth?: number;
        orderBookType?: OrderBookType;
    }) => void;
    unsubscribeOrderBook: (instrumentId: string | string[], options?: {
        depth?: number;
        orderBookType?: OrderBookType;
    }) => void;
    subscribeTrades: (instrumentId: string | string[], options?: {
        tradeSource?: TradeSourceType;
        withOpenInterest?: boolean;
    }) => void;
    unsubscribeTrades: (instrumentId: string | string[], options?: {
        tradeSource?: TradeSourceType;
        withOpenInterest?: boolean;
    }) => void;
    close: () => Promise<void>;
};
export declare const createMarketDataStreamController: (client: MarketDataStreamClient, options?: CreateMarketDataStreamControllerOptions) => MarketDataStreamController;
export {};