package project.data.websocket.client;
|
|
import project.data.websocket.client.req.market.SubMarketDepthRequest;
|
import project.data.websocket.client.req.market.SubMarketTickerRequest;
|
import project.data.websocket.client.req.market.SubMarketTradeRequest;
|
import project.data.websocket.constant.Options;
|
import project.data.websocket.constant.enums.ExchangeEnum;
|
import project.data.websocket.exception.SDKException;
|
import project.data.websocket.model.market.MarketDepthEvent;
|
import project.data.websocket.model.market.MarketTickerEvent;
|
import project.data.websocket.model.market.MarketTradeEvent;
|
import project.data.websocket.service.huobi.HuobiMarketService;
|
import project.data.websocket.utils.ResponseCallback;
|
|
public interface MarketClient {
|
|
void subMarketDepth(SubMarketDepthRequest request, ResponseCallback<MarketDepthEvent> callback);
|
|
void subMarketTrade(SubMarketTradeRequest request, ResponseCallback<MarketTradeEvent> callback);
|
|
void subMarketTicker(SubMarketTickerRequest request, ResponseCallback<MarketTickerEvent> callback);
|
|
static MarketClient create(Options options) {
|
if (options.getExchange().equals(ExchangeEnum.HUOBI)) {
|
return new HuobiMarketService(options);
|
}
|
throw new SDKException(SDKException.INPUT_ERROR, "Unsupport Exchange.");
|
}
|
}
|
