Package info.bitrich.xchangestream.gateio

Class GateioStreamingMarketDataService

java.lang.Object

info.bitrich.xchangestream.gateio.GateioStreamingMarketDataService

All Implemented Interfaces:

StreamingMarketDataService

public class GateioStreamingMarketDataService
extends Object
implements StreamingMarketDataService

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_DEPTH_DEFAULT
static final int	UPDATE_INTERVAL_DEFAULT

Constructor Summary

Constructors

Constructor	Description
GateioStreamingMarketDataService(GateioStreamingService service)

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Observable<OrderBook>	getOrderBook(CurrencyPair currencyPair, Object... args)	Uses the limited-level snapshot method: https://www.gate.io/docs/apiv4/ws/index.html#limited-level-full-order-book-snapshot
io.reactivex.rxjava3.core.Observable<Ticker>	getTicker(CurrencyPair currencyPair, Object... args)	Get a ticker representing the current exchange rate.
io.reactivex.rxjava3.core.Observable<Trade>	getTrades(CurrencyPair currencyPair, Object... args)	Get the trades performed by the exchange.

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, getTrades

Field Details

MAX_DEPTH_DEFAULT

public static final int MAX_DEPTH_DEFAULT

See Also:

• Constant Field Values

UPDATE_INTERVAL_DEFAULT

public static final int UPDATE_INTERVAL_DEFAULT

See Also:

• Constant Field Values

Constructor Details

GateioStreamingMarketDataService

public GateioStreamingMarketDataService(GateioStreamingService service)

Method Details

getOrderBook

public io.reactivex.rxjava3.core.Observable<OrderBook> getOrderBook(CurrencyPair currencyPair,
 Object... args)

Uses the limited-level snapshot method: https://www.gate.io/docs/apiv4/ws/index.html#limited-level-full-order-book-snapshot

Specified by:

getOrderBook in interface StreamingMarketDataService

Parameters:

currencyPair - Currency pair of the order book

args - Order book level: Integer, update speed: Duration

Returns:

Observable that emits OrderBook when exchange sends the update.

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.