Class NatsObserver<T>

Namespace

Virtufin.Data

Assembly

Virtufin.Data.dll

public class NatsObserver<T> : IObserver<T>

Type Parameters

T

Inheritance

object

NatsObserver<T>

Implements

IObserver<T>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

NatsObserver(NatsConnection, Func<T, string>, Func<T, byte[]>)

public NatsObserver(NatsConnection connection, Func<T, string> subjectFactory, Func<T, byte[]> converter)

Parameters

connection NatsConnection

subjectFactory Func<T, string>

converter Func<T, byte[]>

NatsObserver(NatsConnection, string, Func<T, byte[]>)

public NatsObserver(NatsConnection connection, string subject, Func<T, byte[]> converter)

Parameters

connection NatsConnection

subject string

converter Func<T, byte[]>

Methods

OnCompleted()

Notifies the observer that the provider has finished sending push-based notifications.

public void OnCompleted()

OnError(Exception)

Notifies the observer that the provider has experienced an error condition.

public void OnError(Exception error)

Parameters

error Exception

An object that provides additional information about the error.

OnNext(T)

Provides the observer with new data.

public void OnNext(T value)

Parameters

value T

The current notification information.