Package info.bitrich.xchangestream.coinsph

Class CoinsphStreamingService

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.coinsph.CoinsphStreamingService

public class CoinsphStreamingService
extends JsonNettyStreamingService

Nested Class Summary

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

NettyStreamingService.NettyWebSocketClientHandler, NettyStreamingService.Subscription

Field Summary

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
CoinsphStreamingService(CoinsphStreamingExchange exchange, StreamingExchangeConfiguration config)	Constructor for User Data Streaming Service.
CoinsphStreamingService(String apiUrl, CoinsphAccountServiceRaw accountServiceRaw, boolean isPrivateService)	Constructor for Public Streaming Service.

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Completable	connect()
io.reactivex.rxjava3.core.Completable	disconnect()
String	getApiUrl()	Gets the API URL for this service.
protected String	getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
String	getSubscribeMessage(String channelName, Object... args)
String	getSubscriptionUniqueId(String channelName, Object... args)
String	getUnsubscribeMessage(String channelName, Object... args)
protected io.netty.handler.codec.http.websocketx.extensions.WebSocketClientExtensionHandler	getWebSocketClientExtensionHandler()
protected void	handleMessage(com.fasterxml.jackson.databind.JsonNode message)
boolean	isConnecting()
io.reactivex.rxjava3.core.Observable<com.fasterxml.jackson.databind.JsonNode>	subscribeChannel(String channelName, Object... args)

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

messageHandler, processArrayMessageSeparately, sendObjectMessage

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

getChannel, getCustomHeaders, getWebSocketClientHandler, handleChannelError, handleChannelMessage, handleError, handleIdle, 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

setBeforeConnectionHandler

Methods inherited from class java.lang.Object

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

Constructor Details

CoinsphStreamingService

public CoinsphStreamingService(CoinsphStreamingExchange exchange,
 StreamingExchangeConfiguration config)
                        throws IOException

Constructor for User Data Streaming Service. Obtains a listenKey and constructs the full WebSocket URI before initializing the superclass.

Parameters:

exchange - The CoinsphStreamingExchange instance.

config - The streaming configuration.

Throws:

IOException - if listenKey cannot be obtained.

CoinsphStreamingService

public CoinsphStreamingService(String apiUrl,
 CoinsphAccountServiceRaw accountServiceRaw,
 boolean isPrivateService)

Constructor for Public Streaming Service.

Parameters:

apiUrl - The WebSocket API URL.

accountServiceRaw - Not used for public streams, can be null.

isPrivateService - Flag to indicate if this is a private service.

Method Details

getApiUrl

public String getApiUrl()

Gets the API URL for this service.

connect

public io.reactivex.rxjava3.core.Completable connect()

Overrides:

connect in class ConnectableService

getChannelNameFromMessage

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

Specified by:

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

Throws:

IOException

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

getWebSocketClientExtensionHandler

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

Overrides:

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

handleMessage

protected void handleMessage(com.fasterxml.jackson.databind.JsonNode message)

Overrides:

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

subscribeChannel

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

Overrides:

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

isConnecting

public boolean isConnecting()

disconnect

public io.reactivex.rxjava3.core.Completable disconnect()

Overrides:

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

getSubscriptionUniqueId

public String getSubscriptionUniqueId(String channelName,
 Object... args)

Overrides:

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