Class NatsObservable

Namespace

Virtufin.Data

Assembly

Virtufin.Data.dll

public class NatsObservable : IObservable<byte[]>

Inheritance

object

NatsObservable

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

NatsObservable(NatsConnection)

public NatsObservable(NatsConnection connection)

Parameters

connection NatsConnection

Methods

Start(string, CancellationToken)

public Task Start(string subject, CancellationToken cancellationToken)

Parameters

subject string

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.