fix gateio orderbook error

knowm · Apr 26, 2024 · a671329 · a671329
1 parent 826b450
commit a671329
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...tream-gateio/src/main/java/info/bitrich/xchangestream/gateio/GateioStreamingAdapters.java b/...tream-gateio/src/main/java/info/bitrich/xchangestream/gateio/GateioStreamingAdapters.java
@@ -94,7 +94,7 @@ public OrderBook toOrderBook(GateioOrderBookNotification notification) {
     Stream<LimitOrder> asks = orderBookPayload.getAsks().stream()
         .map(priceSizeEntry -> new LimitOrder(OrderType.ASK, priceSizeEntry.getSize(), orderBookPayload.getCurrencyPair(), null, null, priceSizeEntry.getPrice()));
 
-    Stream<LimitOrder> bids = orderBookPayload.getAsks().stream()
+    Stream<LimitOrder> bids = orderBookPayload.getBids().stream()
         .map(priceSizeEntry -> new LimitOrder(OrderType.BID, priceSizeEntry.getSize(), orderBookPayload.getCurrencyPair(), null, null, priceSizeEntry.getPrice()));
 
     return new OrderBook(Date.from(orderBookPayload.getTimestamp()), asks, bids);

diff --git a/...eio/src/main/java/info/bitrich/xchangestream/gateio/GateioStreamingMarketDataService.java b/...eio/src/main/java/info/bitrich/xchangestream/gateio/GateioStreamingMarketDataService.java
@@ -35,7 +35,8 @@ public GateioStreamingMarketDataService(GateioStreamingService service) {
   @Override
   public Observable<OrderBook> getOrderBook(CurrencyPair currencyPair, Object... args) {
     Integer orderBookLevel = (Integer) ArrayUtils.get(args, 0, MAX_DEPTH_DEFAULT);
-    Duration updateSpeed = (Duration) ArrayUtils.get(args, 1, UPDATE_INTERVAL_DEFAULT);
+    Integer updateTime = Integer.parseInt(ArrayUtils.get(args, 1, UPDATE_INTERVAL_DEFAULT).toString());
+    Duration updateSpeed =  Duration.ofMillis(updateTime);
     return service
         .subscribeChannel(Config.SPOT_ORDERBOOK_CHANNEL, new Object[]{currencyPair, orderBookLevel, updateSpeed})
         .map(GateioOrderBookNotification.class::cast)