Class DefaultValueStream<TValue>

Namespace

PushTechnology.ClientInterface.Client.Features.Topics

Assembly

Diffusion.Client.dll

Represents the abstract default value stream.

public class DefaultValueStream<TValue> : DefaultSubscriberStream, IValueStream<TValue>, ISubscriberStream, IStream, ICallback

Type Parameters

TValue

The value type.

Inheritance

object

DefaultCallback

DefaultStream

DefaultSubscriberStream

DefaultValueStream<TValue>

Implements

IValueStream<TValue>

ISubscriberStream

IStream

ICallback

Inherited Members

DefaultSubscriberStream.OnSubscription(string, ITopicSpecification)

DefaultSubscriberStream.OnUnsubscription(string, ITopicSpecification, TopicUnsubscribeReason)

DefaultStream.OnClose()

DefaultCallback.OnError(ErrorReason)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Remarks

This logs all calls at 'Debug' level. These implementations may be useful during development but are usually overridden to provide meaningful processing.

Since 5.8

Methods

OnValue(string, ITopicSpecification, TValue, TValue)

Notifies an update to a topic value from the server.

public virtual void OnValue(string topicPath, ITopicSpecification specification, TValue oldValue, TValue newValue)

Parameters

topicPath string

The topic path.

specification ITopicSpecification

The topic specification.

oldValue TValue

The previous value, which may be null if this is the first value.

newValue TValue

The new value derived from the last update received from the server.

Remarks

This is also called to provide the current value for any matching topic that the client is already subscribed to when the stream is added.