Class WebSocketClientWrapper

Namespace

Virtufin.WebSocketManager.Services

Assembly

Virtufin.WebSocketManager.dll

public class WebSocketClientWrapper : IWebSocketClientWrapper

Inheritance

object

WebSocketClientWrapper

Implements

IWebSocketClientWrapper

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

WebSocketClientWrapper(ILogger<WebSocketClientWrapper>, IOptions<WebSocketOptions>, ApiLifecyclePublisher?)

public WebSocketClientWrapper(ILogger<WebSocketClientWrapper> logger, IOptions<WebSocketOptions> options, ApiLifecyclePublisher? lifecycle = null)

Parameters

logger ILogger<WebSocketClientWrapper>

options IOptions<WebSocketOptions>

lifecycle ApiLifecyclePublisher

Methods

ConnectAsync(WebSocketConnection)

public Task ConnectAsync(WebSocketConnection connection)

Parameters

connection WebSocketConnection

Returns

Task

DisconnectAsync(WebSocketConnection)

public Task DisconnectAsync(WebSocketConnection connection)

Parameters

connection WebSocketConnection

Returns

Task

SendAndWaitAsync(WebSocketConnection, byte[], int, string)

public Task<byte[]> SendAndWaitAsync(WebSocketConnection connection, byte[] message, int timeoutMs, string contentType)

Parameters

connection WebSocketConnection

message byte[]

timeoutMs int

contentType string

Returns

Task<byte[]>

SendAsync(WebSocketConnection, byte[], string)

public Task SendAsync(WebSocketConnection connection, byte[] message, string contentType)

Parameters

connection WebSocketConnection

message byte[]

contentType string

Returns

Task

StartReceiveLoop(WebSocketConnection, Func<byte[], string, Task>)

public void StartReceiveLoop(WebSocketConnection connection, Func<byte[], string, Task> onMessageReceived)

Parameters

connection WebSocketConnection

onMessageReceived Func<byte[], string, Task>