ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket Class Reference

Inheritance diagram for ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket:

Collaboration diagram for ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket:

Public Member Functions
	ConnectorWebsocket (int requestPerPeriod, TimeSpan period)
	Private websocket connections.
	ConnectorWebsocket (int requestPerPeriod, TimeSpan period, IRequestSerializer serializer, RateLimiter? connectionLimiter=null, RateLimiter? crossMessageLimiter=null, string? connectorId=null)
	Public websocket connections.
async Task	Start ()
async Task	StopAsync ()
bool	SubscribeMarketData (Security security, SubscriptionType subType)
	Subscription request.
bool	SubscribeMarketData (IEnumerable< Security > securities, SubscriptionType subType)
	Market data subscription bulk request.
void	SubscribeLiquidations (IEnumerable< Security > securities)
	Liquidation subscription request.
void	UnsubscribeLiquidations (IEnumerable< Security > securities)
	Liquidation subscription request.
bool	UnsubscribeMarketData (Security security, SubscriptionType subType)
	Cancelling market data subscription request.
bool	UnsubscribeMarketData (IEnumerable< Security > securities, SubscriptionType subType)
	Cancelling market data subscription bulk request.
void	Send (object message)
	Single request.
void	SendImmediate (object message)
	Send request as soon as possible.
void	SabotageConnection ()
	For test purposes only.
void	SabotageInitialization ()
	For test purposes only.

Properties
IRequestSerializer?	Serializer [get]
bool	IsPublic [get]
ConnectionStates	ConnectionState [get]
TimeSpan	ReconnectionInterval = TimeSpan.FromSeconds(5) [get]
bool	IsConnected [get]
string	Url [get, set]
TimeSpan	Timeout = TimeSpan.FromSeconds(30) [get]

Events
Action< ConnectorWebsocket >?	Connected
Action< ConnectorWebsocket, WebsocketException >?	Error
Action< ConnectorWebsocket, string >?	Message

Constructor & Destructor Documentation

ConnectorWebsocket() [1/2]

ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.ConnectorWebsocket	(	int	requestPerPeriod,
		TimeSpan	period
	)

Private websocket connections.

Parameters

requestPerPeriod
period

ConnectorWebsocket() [2/2]

ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.ConnectorWebsocket	(	int	requestPerPeriod,
		TimeSpan	period,
		IRequestSerializer	serializer,
		RateLimiter?	connectionLimiter = null,
		RateLimiter?	crossMessageLimiter = null,
		string?	connectorId = null
	)

Public websocket connections.

Parameters

requestPerPeriod
period
serializer
connectionLimiter
crossMessageLimiter
connectorId

Member Function Documentation

SabotageConnection()

void ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.SabotageConnection

(

)

For test purposes only.

SabotageInitialization()

void ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.SabotageInitialization

(

)

For test purposes only.

Send()

void ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.Send

(

object

message

)

Single request.

Parameters

message

SendImmediate()

void ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.SendImmediate

(

object

message

)

Send request as soon as possible.

Parameters

message

Start()

async Task ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.Start

(

)

StopAsync()

async Task ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.StopAsync

(

)

SubscribeLiquidations()

void ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.SubscribeLiquidations

(

IEnumerable< Security >

securities

)

Liquidation subscription request.

Parameters

securities

SubscribeMarketData() [1/2]

bool ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.SubscribeMarketData	(	IEnumerable< Security >	securities,
		SubscriptionType	subType
	)

Market data subscription bulk request.

Parameters

securities
subType

SubscribeMarketData() [2/2]

bool ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.SubscribeMarketData	(	Security	security,
		SubscriptionType	subType
	)

Subscription request.

Parameters

security
subType

UnsubscribeLiquidations()

void ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.UnsubscribeLiquidations

(

IEnumerable< Security >

securities

)

Liquidation subscription request.

Parameters

securities

UnsubscribeMarketData() [1/2]

bool ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.UnsubscribeMarketData	(	IEnumerable< Security >	securities,
		SubscriptionType	subType
	)

Cancelling market data subscription bulk request.

Parameters

securities
subType

UnsubscribeMarketData() [2/2]

bool ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.UnsubscribeMarketData	(	Security	security,
		SubscriptionType	subType
	)

Cancelling market data subscription request.

Parameters

security
subType

Property Documentation

ConnectionState

ConnectionStates ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.ConnectionState

get

IsConnected

bool ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.IsConnected

get

IsPublic

bool ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.IsPublic

get

ReconnectionInterval

TimeSpan ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.ReconnectionInterval = TimeSpan.FromSeconds(5)

get

Serializer

IRequestSerializer? ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.Serializer

get

Timeout

TimeSpan ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.Timeout = TimeSpan.FromSeconds(30)

get

Url

string ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.Url

getset

Event Documentation

Connected

Action<ConnectorWebsocket>? ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.Connected

Error

Action<ConnectorWebsocket, WebsocketException>? ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.Error

Message

Action<ConnectorWebsocket, string>? ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.Message

---

The documentation for this class was generated from the following file:

• ConnectorWebsocket.cs