Class GateioStreamingService

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

GateioStreamingService

public class GateioStreamingService
extends JsonNettyStreamingService

Author: Max Gao (gaamox@tutanota.com) Created: 05-05-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	SPOT_ORDERBOOK_CHANNEL
static final String	SPOT_TICKERS_CHANNEL
static final String	SPOT_TRADES_CHANNEL

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
GateioStreamingService(String apiUri, ExchangeSpecification exchangeSpecification)

Method Summary

Modifier and Type	Method	Description
protected String	getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
ProductSubscription	getProduct()
io.reactivex.Observable<GateioWebSocketTransaction>	getRawWebSocketTransactions(CurrencyPair currencyPair, String channelName, Object... args)
String	getSubscribeMessage(String channelName, Object... args)	Returns a JSON String containing the subscription message.
String	getUnsubscribeMessage(String channelName, Object... args)
protected io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler	getWebSocketClientExtensionHandler()
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, 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

SPOT_ORDERBOOK_CHANNEL

public static final String SPOT_ORDERBOOK_CHANNEL

See Also:

• Constant Field Values

SPOT_TRADES_CHANNEL

public static final String SPOT_TRADES_CHANNEL

See Also:

• Constant Field Values

SPOT_TICKERS_CHANNEL

public static final String SPOT_TICKERS_CHANNEL

See Also:

• Constant Field Values

Constructor Details

GateioStreamingService

public GateioStreamingService(String apiUri,
 ExchangeSpecification exchangeSpecification)

Method Details

getRawWebSocketTransactions

public io.reactivex.Observable<GateioWebSocketTransaction> getRawWebSocketTransactions(CurrencyPair currencyPair,
 String channelName,
 Object... args)

subscribeMultipleCurrencyPairs

public void subscribeMultipleCurrencyPairs(ProductSubscription... products)

getProduct

public ProductSubscription getProduct()

getChannelNameFromMessage

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

Specified by:

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

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

Returns a JSON String containing the subscription message.

Specified by:

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

Parameters:

channelName -

args - CurrencyPair to subscribe to

Returns:

Throws:

IOException

getWebSocketClientExtensionHandler

protected io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler getWebSocketClientExtensionHandler()

Overrides:

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

getUnsubscribeMessage

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

Specified by:

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

Throws:

IOException