package com.yami.trading.huobi.websocket;
|
|
import com.yami.trading.huobi.websocket.client.MarketClient;
|
import com.yami.trading.huobi.websocket.client.req.market.MarketDetailMergedRequest;
|
import com.yami.trading.huobi.websocket.client.req.market.SubMarketTickerRequest;
|
import com.yami.trading.huobi.websocket.constant.HuobiOptions;
|
import com.yami.trading.huobi.websocket.model.market.MarketDetailMerged;
|
import com.yami.trading.huobi.websocket.model.market.MarketTicker;
|
|
import java.util.List;
|
|
public class HuobiTest {
|
|
public static void main(String[] args) {
|
|
MarketClient marketClient = MarketClient.create(new HuobiOptions());
|
//List<MarketTicker> tickers = marketClient.getTickers();
|
//System.out.println(
|
// tickers
|
//);
|
|
//wss行情订阅
|
String test = "berausdt";
|
SubMarketTickerRequest symbolObj = SubMarketTickerRequest.builder().symbol(test).build();
|
marketClient.subMarketTicker(symbolObj, (ticker) -> {
|
System.out.println(ticker);
|
});
|
|
}
|
}
|