| | |
| | | long latestSameLineKlineTs = latestSameLineKline.getTs(); |
| | | klineOneTop5 = klineOneTop5.stream().filter(r -> r.getTs() > latestSameLineKlineTs).collect(Collectors.toList()); |
| | | } |
| | | |
| | | if (klineOneTop5.isEmpty()) { |
| | | return null; |
| | | } |
| | | |
| | | Double high = null; |
| | | Double low = null; |
| | |
| | | if (latestKilne != null && latestKilne.getTs() >= realtime.getTs()) { |
| | | return null; |
| | | } |
| | | long lastKlineTs = latestKilne.getTs(); |
| | | realTimeList = realTimeList.stream().filter(r -> r.getTs() > lastKlineTs).collect(Collectors.toList()); |
| | | if (latestKilne != null) { |
| | | long lastKlineTs = latestKilne.getTs(); |
| | | realTimeList = realTimeList.stream().filter(r -> r.getTs() > lastKlineTs).collect(Collectors.toList()); |
| | | } |
| | | if (realTimeList.isEmpty()) { |
| | | return null; |
| | | } |
| | | Double high = null; |
| | | Double low = null; |
| | | for (Realtime realTime : realTimeList) { |