Package info.bitrich.xchangestream.bitmex

Class BitmexStreamingMarketDataService

java.lang.Object
info.bitrich.xchangestream.bitmex.BitmexStreamingMarketDataService
All Implemented Interfaces:
StreamingMarketDataService
public class BitmexStreamingMarketDataService extends Object implements StreamingMarketDataService
Created by Lukas Zaoralek on 13.11.17.

  • Constructor Details

  • 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.

    • getRawOrderBook

      public io.reactivex.rxjava3.core.Observable<RawOrderBook> getRawOrderBook(CurrencyPair currencyPair)

    • getRawTicker

      public io.reactivex.rxjava3.core.Observable<BitmexTicker> getRawTicker(CurrencyPair currencyPair)

    • getTicker

      public io.reactivex.rxjava3.core.Observable<Ticker> getTicker(CurrencyPair currencyPair, Object... args)
      Description copied from interface: StreamingMarketDataService
      Get a ticker representing the current exchange rate. Emits NotConnectedException When not connected to the WebSocket API.

      Warning: There are currently no guarantees that messages will not be skipped, or that any initial state message will be sent on connection.

      Specified by:
      getTicker in interface StreamingMarketDataService
      Parameters:
      currencyPair - Currency pair of the ticker
      Returns:
      Observable that emits Ticker when exchange sends the update.

    • getTrades

      public io.reactivex.rxjava3.core.Observable<Trade> getTrades(CurrencyPair currencyPair, Object... args)
      Description copied from interface: StreamingMarketDataService
      Get the trades performed by the exchange. Emits NotConnectedException When not connected to the WebSocket API.

      Warning: There are currently no guarantees that messages will not be skipped.

      Specified by:
      getTrades in interface StreamingMarketDataService
      Parameters:
      currencyPair - Currency pair of the trades
      Returns:
      Observable that emits Trade when exchange sends the update.

    • getRawExecutions

      public io.reactivex.rxjava3.core.Observable<BitmexExecution> getRawExecutions(String symbol)

    • enableDeadManSwitch

      public void enableDeadManSwitch() throws IOException
      Throws:
      IOException

    • enableDeadManSwitch

      public void enableDeadManSwitch(long rate, long timeout) throws IOException
      Parameters:
      rate - in milliseconds to send updated
      timeout - milliseconds from now after which orders will be cancelled
      Throws:
      IOException

    • isDeadManSwitchEnabled

      public boolean isDeadManSwitchEnabled() throws IOException
      Throws:
      IOException

    • disableDeadMansSwitch

      public void disableDeadMansSwitch() throws IOException
      Throws:
      IOException

    • getRawFunding

      public io.reactivex.rxjava3.core.Observable<BitmexFunding> getRawFunding()