Class GateioStreamingMarketDataService
java.lang.Object
GateioStreamingMarketDataService
- All Implemented Interfaces:
StreamingMarketDataService
Author: Max Gao (gaamox@tutanota.com) Created: 05-05-2021
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionio.reactivex.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-snapshotio.reactivex.Observable<Ticker>
getTicker
(CurrencyPair currencyPair, Object... args) Get a ticker representing the current exchange rate.io.reactivex.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, getTicker, getTrades
-
Constructor Details
-
GateioStreamingMarketDataService
-
-
Method Details
-
getOrderBook
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 interfaceStreamingMarketDataService
- Parameters:
currencyPair
- Currency pair of the order bookargs
- Optional maxDepth, Optional msgInterval- Returns:
-
getTicker
Description copied from interface:StreamingMarketDataService
Get a ticker representing the current exchange rate. EmitsNotConnectedException
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 interfaceStreamingMarketDataService
- Parameters:
currencyPair
- Currency pair of the ticker- Returns:
Observable
that emitsTicker
when exchange sends the update.
-
getTrades
Description copied from interface:StreamingMarketDataService
Get the trades performed by the exchange. EmitsNotConnectedException
When not connected to the WebSocket API.Warning: There are currently no guarantees that messages will not be skipped.
- Specified by:
getTrades
in interfaceStreamingMarketDataService
- Parameters:
currencyPair
- Currency pair of the trades- Returns:
Observable
that emitsTrade
when exchange sends the update.
-