| | |
|---|
| | | private final AtomicBoolean isConnecting = new AtomicBoolean(false); |
|---|
| | | private final AtomicBoolean isInitialized = new AtomicBoolean(false); |
|---|
| | | |
|---|
| | | private static final String CHANNEL = "candle15m"; |
|---|
| | | private static final String CHANNEL = "candle5m"; |
|---|
| | | // private static final String CHANNEL = "candle15m"; |
|---|
| | | |
|---|
| | | // 心跳超时时间(秒)，小于30秒 |
|---|
| | | private static final int HEARTBEAT_TIMEOUT = 10; |
|---|
| | |
|---|
| | | List<BigDecimal> low = kline15MinuteData.stream() |
|---|
| | | .map(Kline::getL) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | List<BigDecimal> close = kline15MinuteData.stream() |
|---|
| | | .map(Kline::getC) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | List<BigDecimal> close = prices; |
|---|
| | | |
|---|
| | | // 生成成交量数据 |
|---|
| | | List<BigDecimal> volume = kline15MinuteData.stream() |
|---|
