Package org.consensusj.exchange.knowm

Class ReactiveKnowmExchangeProvider

java.lang.Object

org.consensusj.exchange.knowm.ReactiveKnowmExchangeProvider

All Implemented Interfaces:

ReactiveExchange

public class ReactiveKnowmExchangeProvider
extends Object
implements ReactiveExchange

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ReactiveKnowmExchangeProvider.MonitoredCurrency

Field Summary

Fields

Modifier and Type	Field	Description
protected org.knowm.xchange.Exchange	exchange
protected final String	exchangeClassName
protected final org.knowm.xchange.ExchangeSpecification	exchangeSpecification
protected final io.reactivex.rxjava3.core.Observable<Long>	interval
protected org.knowm.xchange.service.marketdata.MarketDataService	marketDataService
protected String	name
protected final Map<CurrencyUnitPair,ReactiveKnowmExchangeProvider.MonitoredCurrency>	observablePairs
protected javax.money.convert.ProviderContext	providerContext
protected final Map<javax.money.CurrencyUnit,String>	tickerSymbolConversions

Constructor Summary

Constructors

Constructor	Description
ReactiveKnowmExchangeProvider(String exchangeClassName, Map<javax.money.CurrencyUnit,String> tickerSymbolConversions, Collection<CurrencyUnitPair> pairs, io.reactivex.rxjava3.core.Observable<Long> interval)
ReactiveKnowmExchangeProvider(org.knowm.xchange.ExchangeSpecification exchangeSpecification, String exchangeClassName, Map<javax.money.CurrencyUnit,String> tickerSymbolConversions, Collection<CurrencyUnitPair> pairs, io.reactivex.rxjava3.core.Observable<Long> interval)
ReactiveKnowmExchangeProvider(org.knowm.xchange.ExchangeSpecification exchangeSpecification, Map<javax.money.CurrencyUnit,String> tickerSymbolConversions, Collection<CurrencyUnitPair> pairs, io.reactivex.rxjava3.core.Observable<Long> interval)

Method Summary

Modifier and Type	Method	Description
String	convertSymbol(javax.money.CurrencyUnit currencyUnit)	Convert a JavaMoney CurrencyUnit to an XChange currency code string (This will be exchange-specific (e.g.
String	getName()
PolledObservablePair	getObservablePair(CurrencyUnitPair pair)
protected org.knowm.xchange.currency.CurrencyPair	xchangePair(CurrencyUnitPair pair)	Map from CurrencyUnitPair to XChange CurrencyPair tickerSymbolConversions is used to handle cases like ItBit that uses "XBT" instead of "BTC"

Methods inherited from class java.lang.Object

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

Field Details

exchangeClassName

protected final String exchangeClassName

tickerSymbolConversions

protected final Map<javax.money.CurrencyUnit,String> tickerSymbolConversions

interval

protected final io.reactivex.rxjava3.core.Observable<Long> interval

exchangeSpecification

protected final org.knowm.xchange.ExchangeSpecification exchangeSpecification

observablePairs

protected final Map<CurrencyUnitPair,ReactiveKnowmExchangeProvider.MonitoredCurrency> observablePairs

name

protected String name

providerContext

protected javax.money.convert.ProviderContext providerContext

marketDataService

protected org.knowm.xchange.service.marketdata.MarketDataService marketDataService

exchange

protected org.knowm.xchange.Exchange exchange

Constructor Details

ReactiveKnowmExchangeProvider

public ReactiveKnowmExchangeProvider(String exchangeClassName,
 Map<javax.money.CurrencyUnit,String> tickerSymbolConversions,
 Collection<CurrencyUnitPair> pairs,
 io.reactivex.rxjava3.core.Observable<Long> interval)

ReactiveKnowmExchangeProvider

public ReactiveKnowmExchangeProvider(org.knowm.xchange.ExchangeSpecification exchangeSpecification,
 Map<javax.money.CurrencyUnit,String> tickerSymbolConversions,
 Collection<CurrencyUnitPair> pairs,
 io.reactivex.rxjava3.core.Observable<Long> interval)

ReactiveKnowmExchangeProvider

public ReactiveKnowmExchangeProvider(org.knowm.xchange.ExchangeSpecification exchangeSpecification,
 String exchangeClassName,
 Map<javax.money.CurrencyUnit,String> tickerSymbolConversions,
 Collection<CurrencyUnitPair> pairs,
 io.reactivex.rxjava3.core.Observable<Long> interval)

Method Details

getName

public String getName()

Specified by:

getName in interface ReactiveExchange

getObservablePair

public PolledObservablePair getObservablePair(CurrencyUnitPair pair)

Specified by:

getObservablePair in interface ReactiveExchange

xchangePair

protected org.knowm.xchange.currency.CurrencyPair xchangePair(CurrencyUnitPair pair)

Map from CurrencyUnitPair to XChange CurrencyPair tickerSymbolConversions is used to handle cases like ItBit that uses "XBT" instead of "BTC"

Parameters:

pair - CurrencyUnitPair using JavaMoney CurrencyUnits

Returns:

XChange CurrencyPair with exchange-specific symbols if any

convertSymbol

public String convertSymbol(javax.money.CurrencyUnit currencyUnit)

Convert a JavaMoney CurrencyUnit to an XChange currency code string (This will be exchange-specific (e.g. ItBit uses "XBT" instead of "BTC")

Parameters:

currencyUnit - A JavaMoney currency unit

Returns:

exchange-specific symbol for the currency