Class dydxStreamingExchange

java.lang.Object
org.knowm.xchange.BaseExchange
org.knowm.xchange.dydx.dydxExchange
info.bitrich.xchangestream.dydx.dydxStreamingExchange
All Implemented Interfaces:
StreamingExchange, Exchange

public class dydxStreamingExchange
extends dydxExchange
implements StreamingExchange
Author: Max Gao (gaamox@tutanota.com) Created: 20-02-2021

V3 Documentation: https://docs.dydx.exchange

Legacy Documentation: https://legacy-docs.dydx.exchange

  • Constructor Details

    • dydxStreamingExchange

      public dydxStreamingExchange()
  • Method Details

    • connect

      public io.reactivex.Completable connect​(ProductSubscription... args)
      Description copied from interface: StreamingExchange
      Connects to the WebSocket API of the exchange.
      Specified by:
      connect in interface StreamingExchange
      Parameters:
      args - Product subscription is used only in certain exchanges where you need to specify subscriptions during the connect phase.
      Returns:
      Completable that completes upon successful connection.
    • disconnect

      public io.reactivex.Completable disconnect()
      Description copied from interface: StreamingExchange
      Disconnect from the WebSocket API.
      Specified by:
      disconnect in interface StreamingExchange
      Returns:
      Completable that completes upon successful disconnect.
    • getStreamingMarketDataService

      public StreamingMarketDataService getStreamingMarketDataService()
      Description copied from interface: StreamingExchange
      Returns service that can be used to access streaming market data.
      Specified by:
      getStreamingMarketDataService in interface StreamingExchange
    • isAlive

      public boolean isAlive()
      Description copied from interface: StreamingExchange
      Checks whether connection to the exchange is alive.
      Specified by:
      isAlive in interface StreamingExchange
      Returns:
      true if connection is open, otherwise false.
    • useCompressedMessages

      public void useCompressedMessages​(boolean compressedMessages)
      Description copied from interface: StreamingExchange
      Set whether or not to enable compression handler.
      Specified by:
      useCompressedMessages in interface StreamingExchange
      Parameters:
      compressedMessages - Defaults to false