Class dydxStreamingMarketDataService

java.lang.Object
info.bitrich.xchangestream.dydx.service.v1.dydxStreamingMarketDataService
All Implemented Interfaces:
StreamingMarketDataService

public class dydxStreamingMarketDataService extends Object implements StreamingMarketDataService
Author: Max Gao (gaamox@tutanota.com) Created: 20-02-2021
  • Constructor Details

    • dydxStreamingMarketDataService

      public dydxStreamingMarketDataService(dydxStreamingService service)
  • Method Details

    • getOrderBook

      public io.reactivex.rxjava3.core.Observable<OrderBook> getOrderBook(CurrencyPair currencyPair, Object... args)
      Description copied from interface: StreamingMarketDataService
      Get an order book representing the current offered exchange rates (market depth).

      Warning: The library will attempt to keep the snapshots returned in sync with the exchange using the approaches published by that exchange. However, there are currently no guarantees that messages will not be skipped, or that any initial state message will be sent on connection. Emits NotConnectedException when not connected to the WebSocket API.

      Specified by:
      getOrderBook in interface StreamingMarketDataService
      Parameters:
      currencyPair - Currency pair of the order book
      Returns:
      Observable that emits OrderBook when exchange sends the update.