Package info.bitrich.xchangestream.dydx.service.v1

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 Summary

Constructors

Constructor	Description
dydxStreamingMarketDataService(dydxStreamingService service)

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Observable<OrderBook>	getOrderBook(CurrencyPair currencyPair, Object... args)	Get an order book representing the current offered exchange rates (market depth).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface info.bitrich.xchangestream.core.StreamingMarketDataService

getFundingRate, getFundingRates, getOrderBook, getOrderBookUpdates, getTicker, getTicker, getTrades, getTrades

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.