Package info.bitrich.xchangestream.bybit

Class BybitStreamingMarketDataService

java.lang.Object

info.bitrich.xchangestream.bybit.BybitStreamingMarketDataService

All Implemented Interfaces:

StreamingMarketDataService

public class BybitStreamingMarketDataService
extends Object
implements StreamingMarketDataService

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ORDERBOOK
static final String	TICKER
static final String	TRADE

Constructor Summary

Constructors

Constructor	Description
BybitStreamingMarketDataService(BybitStreamingService streamingService)

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Observable<OrderBook>	getOrderBook(Instrument instrument, Object... args)	Linear invalid input: '&' inverse: Level 1 data, push frequency: 10ms Level 50 data, push frequency: 20ms Level 200 data, push frequency: 100ms Level 500 data, push frequency: 100ms Spot: Level 1 data, push frequency: 10ms Level 50 data, push frequency: 20ms Level 200 data, push frequency: 200ms
io.reactivex.rxjava3.core.Observable<List<OrderBookUpdate>>	getOrderBookUpdates(Instrument instrument, Object... args)	Get snapshots of orderBook update separately.
io.reactivex.rxjava3.core.Observable<Trade>	getTrades(Instrument instrument, Object... args)

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

Field Details

TRADE

public static final String TRADE

See Also:

• Constant Field Values

ORDERBOOK

public static final String ORDERBOOK

See Also:

• Constant Field Values

TICKER

public static final String TICKER

See Also:

• Constant Field Values

Constructor Details

BybitStreamingMarketDataService

public BybitStreamingMarketDataService(BybitStreamingService streamingService)

Method Details

getOrderBook

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

Linear invalid input: '&' inverse: Level 1 data, push frequency: 10ms Level 50 data, push frequency: 20ms Level 200 data, push frequency: 100ms Level 500 data, push frequency: 100ms Spot: Level 1 data, push frequency: 10ms Level 50 data, push frequency: 20ms Level 200 data, push frequency: 200ms

Specified by:

getOrderBook in interface StreamingMarketDataService

Parameters:

args - - orderbook depth

getOrderBookUpdates

public io.reactivex.rxjava3.core.Observable<List<OrderBookUpdate>> getOrderBookUpdates(Instrument instrument,
 Object... args)

Description copied from interface: StreamingMarketDataService

Get snapshots of orderBook update separately. Work only with StreamingMarketDataService.getOrderBook(Instrument, Object...) subscription.

Specified by:

getOrderBookUpdates in interface StreamingMarketDataService

Returns:

Observable that emits OrderBookUpdate when exchange sends the orderBook snapshot.

getTrades

public io.reactivex.rxjava3.core.Observable<Trade> getTrades(Instrument instrument,
 Object... args)

Specified by:

getTrades in interface StreamingMarketDataService