Package info.bitrich.xchangestream.bybit

Class BybitStreamingExchange

java.lang.Object

org.knowm.xchange.BaseExchange

org.knowm.xchange.bybit.BybitExchange

info.bitrich.xchangestream.bybit.BybitStreamingExchange

All Implemented Interfaces:

StreamingExchange, Exchange

public class BybitStreamingExchange
extends BybitExchange
implements StreamingExchange

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AUTH_URI
static final String	DEMO_AUTH_URI
static final String	DEMO_URI
static final String	EXCHANGE_TYPE
static final String	TESTNET_AUTH_URI
static final String	TESTNET_URI
static final String	URI

Fields inherited from class org.knowm.xchange.bybit.BybitExchange

SPECIFIC_PARAM_ACCOUNT_TYPE

Fields inherited from class org.knowm.xchange.BaseExchange

accountService, exchangeMetaData, exchangeSpecification, logger, marketDataService, tradeService

Fields inherited from interface org.knowm.xchange.Exchange

USE_SANDBOX

Fields inherited from interface info.bitrich.xchangestream.core.StreamingExchange

ACCEPT_ALL_CERITICATES, AUTO_RECONNECT, ENABLE_LOGGING_HANDLER, L3_ORDERBOOK, SOCKS_PROXY_HOST, SOCKS_PROXY_PORT

Constructor Summary

Constructors

Constructor	Description
BybitStreamingExchange()

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Completable	connect(ProductSubscription... args)	Connects to the WebSocket API of the exchange.
io.reactivex.rxjava3.core.Completable	disconnect()	Disconnect from the WebSocket API.
BybitStreamingMarketDataService	getStreamingMarketDataService()	Returns service that can be used to access streaming market data.
BybitStreamingTradeService	getStreamingTradeService()	Returns service that can be used to access streaming trade data.
protected void	initServices()
boolean	isAlive()	Checks whether connection to the exchange is alive.
void	useCompressedMessages(boolean compressedMessages)	Set whether or not to enable compression handler.

Methods inherited from class org.knowm.xchange.bybit.BybitExchange

applySpecification, getDefaultExchangeSpecification, remoteInit

Methods inherited from class org.knowm.xchange.BaseExchange

getAccountService, getExchangeInstruments, getExchangeMetaData, getExchangeSpecification, getMarketDataService, getMetaDataFileName, getNonceFactory, getTradeService, loadExchangeMetaData, loadMetaData, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.knowm.xchange.Exchange

applySpecification, getAccountService, getDefaultExchangeSpecification, getExchangeInstruments, getExchangeMetaData, getExchangeSpecification, getMarketDataService, getNonceFactory, getResilienceRegistries, getTradeService, remoteInit

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

applyStreamingSpecification, connectionIdle, connectionStateObservable, connectionSuccess, disconnectObservable, getStreamingAccountService, messageDelay, reconnectFailure, resubscribeChannels

Field Details

URI

public static final String URI

See Also:

• Constant Field Values

TESTNET_URI

public static final String TESTNET_URI

See Also:

• Constant Field Values

DEMO_URI

public static final String DEMO_URI

See Also:

• Constant Field Values

AUTH_URI

public static final String AUTH_URI

See Also:

• Constant Field Values

TESTNET_AUTH_URI

public static final String TESTNET_AUTH_URI

See Also:

• Constant Field Values

DEMO_AUTH_URI

public static final String DEMO_AUTH_URI

See Also:

• Constant Field Values

EXCHANGE_TYPE

public static final String EXCHANGE_TYPE

See Also:

• Constant Field Values

Constructor Details

BybitStreamingExchange

public BybitStreamingExchange()

Method Details

initServices

protected void initServices()

Overrides:

initServices in class BybitExchange

connect

public io.reactivex.rxjava3.core.Completable connect(ProductSubscription... args)

Description copied from interface: StreamingExchange

Connects to the WebSocket API of the exchange.

Specified by:

connect in interface StreamingExchange

Parameters:

args - Product subscription is used only in certain exchanges where you need to specify subscriptions during the connect phase.

Returns:

Completable that completes upon successful connection.

disconnect

public io.reactivex.rxjava3.core.Completable disconnect()

Description copied from interface: StreamingExchange

Disconnect from the WebSocket API.

Specified by:

disconnect in interface StreamingExchange

Returns:

Completable that completes upon successful disconnect.

isAlive

public boolean isAlive()

Description copied from interface: StreamingExchange

Checks whether connection to the exchange is alive.

Specified by:

isAlive in interface StreamingExchange

Returns:

true if connection is open, otherwise false.

useCompressedMessages

public void useCompressedMessages(boolean compressedMessages)

Description copied from interface: StreamingExchange

Set whether or not to enable compression handler.

Specified by:

useCompressedMessages in interface StreamingExchange

Parameters:

compressedMessages - Defaults to false

getStreamingMarketDataService

public BybitStreamingMarketDataService getStreamingMarketDataService()

Description copied from interface: StreamingExchange

Returns service that can be used to access streaming market data.

Specified by:

getStreamingMarketDataService in interface StreamingExchange

getStreamingTradeService

public BybitStreamingTradeService getStreamingTradeService()

Description copied from interface: StreamingExchange

Returns service that can be used to access streaming trade data.

Specified by:

getStreamingTradeService in interface StreamingExchange