Loading...
Searching...
No Matches
Public Member Functions | Properties | Events | List of all members
ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket Class Reference
Inheritance diagram for ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket:
[legend]
Collaboration diagram for ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket:
[legend]

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 = null! [get, set]
 
TimeSpan Timeout = TimeSpan.FromSeconds(30) [get]
 
TaskCompletionSource PrivateConnectionSource = new() [get, set]
 Completion source for custom connection conditions.
 
Func< ReadOnlyMemory< byte >, bool >? BytesMessageFilter [get, set]
 Optional pre-filter for received text messages, called on the socket read loop before any event is raised. Return false to drop the message without decoding or deserializing it (see SnapshotMessageThrottle).
 

Events

Action< ConnectorWebsocket >? Connected
 
Action< ConnectorWebsocket, WebsocketException >? Error
 
Action< ConnectorWebsocket, string >? Message
 
Action< ConnectorWebsocket, ReadOnlyMemory< byte > >? BytesMessage
 Raw UTF-8 payload of a text message. The memory is rented and is valid only during the handler call.
 

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

◆ BytesMessageFilter

Func<ReadOnlyMemory<byte>, bool>? ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.BytesMessageFilter
getset

Optional pre-filter for received text messages, called on the socket read loop before any event is raised. Return false to drop the message without decoding or deserializing it (see SnapshotMessageThrottle).

◆ ConnectionState

ConnectionStates ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.ConnectionState
get

◆ IsConnected

bool ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.IsConnected
get

◆ IsPublic

bool ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.IsPublic
get

◆ PrivateConnectionSource

TaskCompletionSource ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.PrivateConnectionSource = new()
getset

Completion source for custom connection conditions.

◆ 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 = null!
getset

Event Documentation

◆ BytesMessage

Action<ConnectorWebsocket, ReadOnlyMemory<byte> >? ATAS.DataFeedsCore.ConnectorWebsocket.ConnectorWebsocket.BytesMessage

Raw UTF-8 payload of a text message. The memory is rented and is valid only during the handler call.

◆ 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: