Class DefaultSubscriberStream

Namespace

PushTechnology.ClientInterface.Client.Features.Topics

Assembly

Diffusion.Client.dll

Represents the abstract default subscriber stream.

public class DefaultSubscriberStream : DefaultStream, ISubscriberStream, IStream, ICallback

Inheritance

object

DefaultCallback

DefaultStream

DefaultSubscriberStream

Implements

ISubscriberStream

IStream

ICallback

Derived

DefaultValueStream<TValue>

Inherited Members

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 calls to OnSubscription and OnUnsubscription at 'Debug' level. These implementations may be useful during development but are usually overridden to provide meaningful processing.

Methods

OnSubscription(string, ITopicSpecification)

This notifies when a topic is subscribed to.

public virtual void OnSubscription(string topicPath, ITopicSpecification specification)

Parameters

topicPath string

The full topic path.

specification ITopicSpecification

The topic specification.

Remarks

This is called when a client becomes subscribed to a topic that matches with the stream. This method is also called when a stream is added that matches a topic to which the session is already subscribed.

This will always be the first notification to the stream for a topic.

Currently, topic properties are not available through this notification.

OnUnsubscription(string, ITopicSpecification, TopicUnsubscribeReason)

This notifies when a topic is unsubscribed.

public virtual void OnUnsubscription(string topicPath, ITopicSpecification specification, TopicUnsubscribeReason reason)

Parameters

topicPath string

The full topic path.

specification ITopicSpecification

The topic specification.

reason TopicUnsubscribeReason

The reason for unsubscription.