Class WebSocketObservable

Namespace

Virtufin.Data

Assembly

Virtufin.Data.dll

public class WebSocketObservable : IObservable<byte[]>

Inheritance

object

WebSocketObservable

Implements

IObservable<byte[]>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

WebSocketObservable(ClientWebSocket)

public WebSocketObservable(ClientWebSocket client)

Parameters

client ClientWebSocket

Methods

Start(Uri, HttpMessageInvoker?, CancellationToken)

public Task Start(Uri uri, HttpMessageInvoker? httpMessageInvoker, CancellationToken cancellationToken)

Parameters

uri Uri

httpMessageInvoker HttpMessageInvoker

cancellationToken CancellationToken

Returns

Task

Start(Uri, CancellationToken)

public Task Start(Uri uri, CancellationToken cancellationToken)

Parameters

uri Uri

cancellationToken CancellationToken

Returns

Task

Subscribe(IObserver<byte[]>)

Notifies the provider that an observer is to receive notifications.

public IDisposable Subscribe(IObserver<byte[]> observer)

Parameters

observer IObserver<byte[]>

The object that is to receive notifications.

Returns

IDisposable

A reference to an interface that allows observers to stop receiving notifications before the provider has finished sending them.