Interface SubscriptionStrategy<T>

All Superinterfaces:

Nameable, Named, Strategy

All Known Subinterfaces:

FundingRateStrategy, KlineStrategy, TickerStrategy

All Known Implementing Classes:

AbstractFundingRateStrategy, AbstractKlineStrategy, AbstractSubscriptionStrategy, AbstractTickerStrategy

public interface SubscriptionStrategy<T>
extends Strategy

Defines a subscription to a stream of updates of type T

Method Summary

Modifier and Type	Method	Description
boolean	accept(T update)
boolean	acceptInstrument(@NonNull Instrument instrument)
MarketDataSource	getMarketDataSource()
void	subscribeSource(@NonNull io.reactivex.rxjava3.core.Observable<T> source)
void	update(T update)
default void	updateFrom(@NonNull List<T> updates)

Methods inherited from interface Nameable

setName

Methods inherited from interface Named

getName

Methods inherited from interface Strategy

applyProperty, configure, getExecutionCallback, getExecutionConfig, getExecutionMode, getId, getInputCurrency, getInstruments, getNotices, getOutputCurrency, getProperty, getProperty, getPropertyInfo, getPropertyInfos, getSignals, getStateStore, getStats, getYields, hasProperty, hasProperty, init, isCurrencyLess, isEnabled, reset, setEnabled, setProperty, setProperty

Method Details

subscribeSource

void subscribeSource(@NonNull
 @NonNull io.reactivex.rxjava3.core.Observable<T> source)

accept

boolean accept(@NonNull
 T update)

acceptInstrument

boolean acceptInstrument(@NonNull
 @NonNull Instrument instrument)

update

void update(@NonNull
 T update)

updateFrom

default void updateFrom(@NonNull
 @NonNull List<T> updates)

getMarketDataSource

MarketDataSource getMarketDataSource()