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	CANDLE
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<CandleStickData>	getCandleStick(Instrument instrument, CandleStickInterval interval)	Get candlestick data.
io.reactivex.rxjava3.core.Observable<FundingRate>	getFundingRate(Instrument instrument, Object... args)	Get funding rate of specific instrument.
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<Ticker>	getTicker(Instrument instrument, Object... args)
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

getFundingRates, getOrderBook, getOrderBookTicker, 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

CANDLE

public static final String CANDLE

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 or several depths

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

getTicker

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

Specified by:

getTicker in interface StreamingMarketDataService

getFundingRate

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

Description copied from interface: StreamingMarketDataService

Get funding rate of specific instrument.

Specified by:

getFundingRate in interface StreamingMarketDataService

Parameters:

instrument - Instrument to get the funding rate for

Returns:

Observable that emits FundingRate when exchange sends the update.

getCandleStick

public io.reactivex.rxjava3.core.Observable<CandleStickData> getCandleStick(Instrument instrument,
 CandleStickInterval interval)

Description copied from interface: StreamingMarketDataService

Get candlestick data.

Specified by:

getCandleStick in interface StreamingMarketDataService

Parameters:

instrument - Instrument to get the candlestick data for

interval - Candlestick interval

Returns:

Observable that emits CandleStickData when exchange sends the update.