info.bitrich.xchangestream.lgo

Class LgoStreamingExchange

java.lang.Object

org.knowm.xchange.BaseExchange

org.knowm.xchange.lgo.LgoExchange

info.bitrich.xchangestream.lgo.LgoStreamingExchange

All Implemented Interfaces:

StreamingExchange, org.knowm.xchange.Exchange

public class LgoStreamingExchange
extends org.knowm.xchange.lgo.LgoExchange
implements StreamingExchange

Field Summary

Fields inherited from class org.knowm.xchange.BaseExchange

exchangeMetaData, exchangeSpecification, logger

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

ACCEPT_ALL_CERITICATES, ENABLE_LOGGING_HANDLER, SOCKS_PROXY_HOST, SOCKS_PROXY_PORT, USE_SANDBOX

Constructor Summary

Constructors

Constructor and Description
LgoStreamingExchange()

Method Summary

Modifier and Type	Method and Description
void	applySpecification(org.knowm.xchange.ExchangeSpecification exchangeSpecification)
io.reactivex.Completable	connect(ProductSubscription... args)
io.reactivex.Completable	disconnect()
LgoStreamingAccountService	getStreamingAccountService()
StreamingMarketDataService	getStreamingMarketDataService()
LgoStreamingTradeService	getStreamingTradeService()
protected void	initServices()
boolean	isAlive()
void	useCompressedMessages(boolean compressedMessages)

Methods inherited from class org.knowm.xchange.lgo.LgoExchange

getCurrencies, getDefaultExchangeSpecification, getMarketDataService, getNonceFactory, getProducts, getSignatureService, getTradeService, remoteInit

Methods inherited from class org.knowm.xchange.BaseExchange

getAccountService, getExchangeMetaData, getExchangeSpecification, getExchangeSymbols, getMetaDataFileName, loadExchangeMetaData, loadMetaData, toString

Methods inherited from class java.lang.Object

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

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

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

Methods inherited from interface org.knowm.xchange.Exchange

getAccountService, getDefaultExchangeSpecification, getExchangeMetaData, getExchangeSpecification, getExchangeSymbols, getMarketDataService, getNonceFactory, getTradeService, remoteInit

Constructor Detail

LgoStreamingExchange

public LgoStreamingExchange()

Method Detail

initServices

protected void initServices()

Overrides:

initServices in class org.knowm.xchange.lgo.LgoExchange

applySpecification

public void applySpecification(org.knowm.xchange.ExchangeSpecification exchangeSpecification)

Specified by:

applySpecification in interface org.knowm.xchange.Exchange

Overrides:

applySpecification in class org.knowm.xchange.BaseExchange

connect

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

Specified by:

connect in interface StreamingExchange

disconnect

public io.reactivex.Completable disconnect()

Specified by:

disconnect in interface StreamingExchange

isAlive

public boolean isAlive()

Specified by:

isAlive in interface StreamingExchange

getStreamingMarketDataService

public StreamingMarketDataService getStreamingMarketDataService()

Specified by:

getStreamingMarketDataService in interface StreamingExchange

getStreamingAccountService

public LgoStreamingAccountService getStreamingAccountService()

Specified by:

getStreamingAccountService in interface StreamingExchange

getStreamingTradeService

public LgoStreamingTradeService getStreamingTradeService()

Specified by:

getStreamingTradeService in interface StreamingExchange

useCompressedMessages

public void useCompressedMessages(boolean compressedMessages)

Specified by:

useCompressedMessages in interface StreamingExchange