1

zj

2025-06-23 dc9bd22833255bc602dd42c7f603ecb50842ab35

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
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.");
    }
}