Package info.bitrich.xchangestream.dydx

Class dydxStreamingService

java.lang.Object

info.bitrich.xchangestream.service.ConnectableService

info.bitrich.xchangestream.service.netty.NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

info.bitrich.xchangestream.service.netty.JsonNettyStreamingService

info.bitrich.xchangestream.dydx.dydxStreamingService

public class dydxStreamingService
extends JsonNettyStreamingService

Author: Max Gao (gaamox@tutanota.com) Created: 20-02-2021

Nested Class Summary

Nested classes/interfaces inherited from class info.bitrich.xchangestream.service.netty.NettyStreamingService

NettyStreamingService.NettyWebSocketClientHandler, NettyStreamingService.Subscription

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CHANNEL_DATA
static final String	ORDERBOOK
static final String	SUBSCRIBED
static final String	V1_ACCOUNTS
static final String	V1_MARKETS
static final String	V1_ORDERBOOK
static final String	V1_TRADES
static final String	V3_ACCOUNTS
static final String	V3_MARKETS
static final String	V3_ORDERBOOK
static final String	V3_TRADES

Fields inherited from class info.bitrich.xchangestream.service.netty.JsonNettyStreamingService

objectMapper

Fields inherited from class info.bitrich.xchangestream.service.netty.NettyStreamingService

channels, DEFAULT_CONNECTION_TIMEOUT, DEFAULT_IDLE_TIMEOUT, DEFAULT_RETRY_DURATION, uri

Fields inherited from class info.bitrich.xchangestream.service.ConnectableService

BEFORE_CONNECTION_HANDLER

Constructor Summary

Constructors

Constructor	Description
dydxStreamingService(String apiUri)

Method Summary

Modifier and Type	Method	Description
protected String	getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
ProductSubscription	getProduct()
io.reactivex.Observable<dydxWebSocketTransaction>	getRawWebsocketTransactions(CurrencyPair currencyPair, String baseChannelName)	Creates an observable of a channel using the baseChannelName and currencyPair.
String	getSubscribeMessage(String channelName, Object... args)
String	getUnsubscribeMessage(String channelName, Object... args)
io.reactivex.Observable<com.fasterxml.jackson.databind.JsonNode>	subscribeChannel(String channelName, Object... args)
void	subscribeMultipleCurrencyPairs(ProductSubscription... products)

Methods inherited from class info.bitrich.xchangestream.service.netty.JsonNettyStreamingService

messageHandler, processArrayMessageSeparately, sendObjectMessage

Methods inherited from class info.bitrich.xchangestream.service.netty.NettyStreamingService

disconnect, getChannel, getCustomHeaders, getSubscriptionUniqueId, getWebSocketClientExtensionHandler, getWebSocketClientHandler, handleChannelError, handleChannelMessage, handleError, handleIdle, handleMessage, isSocketOpen, openConnection, resubscribeChannels, sendMessage, setAcceptAllCertificates, setAutoReconnect, setEnableLoggingHandler, setLoggingHandlerLevel, setSocksProxyHost, setSocksProxyPort, subscribeConnectionState, subscribeConnectionSuccess, subscribeDisconnect, subscribeIdle, subscribeReconnectFailure, useCompressedMessages

Methods inherited from class info.bitrich.xchangestream.service.ConnectableService

connect, setBeforeConnectionHandler

Methods inherited from class java.lang.Object

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

Field Details

SUBSCRIBED

public static final String SUBSCRIBED

See Also:

• Constant Field Values

CHANNEL_DATA

public static final String CHANNEL_DATA

See Also:

• Constant Field Values

V3_ORDERBOOK

public static final String V3_ORDERBOOK

See Also:

• Constant Field Values

V3_TRADES

public static final String V3_TRADES

See Also:

• Constant Field Values

V3_ACCOUNTS

public static final String V3_ACCOUNTS

See Also:

• Constant Field Values

V3_MARKETS

public static final String V3_MARKETS

See Also:

• Constant Field Values

V1_ORDERBOOK

public static final String V1_ORDERBOOK

See Also:

• Constant Field Values

V1_TRADES

public static final String V1_TRADES

See Also:

• Constant Field Values

V1_ACCOUNTS

public static final String V1_ACCOUNTS

See Also:

• Constant Field Values

V1_MARKETS

public static final String V1_MARKETS

See Also:

• Constant Field Values

ORDERBOOK

public static final String ORDERBOOK

See Also:

• Constant Field Values

Constructor Details

dydxStreamingService

public dydxStreamingService(String apiUri)

Method Details

getChannelNameFromMessage

protected String getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)

Specified by:

getChannelNameFromMessage in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

getProduct

public ProductSubscription getProduct()

subscribeMultipleCurrencyPairs

public void subscribeMultipleCurrencyPairs(ProductSubscription... products)

getRawWebsocketTransactions

public io.reactivex.Observable<dydxWebSocketTransaction> getRawWebsocketTransactions(CurrencyPair currencyPair,
 String baseChannelName)

Creates an observable of a channel using the baseChannelName and currencyPair. For example, subscribing to the trades channel for WETH/USDC will create a new channel "trades-WETH-USDC".

Parameters:

currencyPair - any currency pair supported by dydx

baseChannelName - e.g. "orderbook", "v3_orderbook", etc.

Returns:

subscribeChannel

public io.reactivex.Observable<com.fasterxml.jackson.databind.JsonNode> subscribeChannel(String channelName,
 Object... args)

Overrides:

subscribeChannel in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

getSubscribeMessage

public String getSubscribeMessage(String channelName,
 Object... args)
                           throws IOException

Specified by:

getSubscribeMessage in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

Throws:

IOException

getUnsubscribeMessage

public String getUnsubscribeMessage(String channelName,
 Object... args)
                             throws IOException

Specified by:

getUnsubscribeMessage in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

Throws:

IOException