Class DefaultSubscriberStream

Represents the abstract default subscriber stream.

Inheritance
System.Object
DefaultCallback
DefaultStream
DefaultSubscriberStream
DefaultValueStream<TValue>
Implements
ISubscriberStream
IStream
ICallback
Inherited Members
DefaultStream.OnClose()
DefaultCallback.OnError(ErrorReason)
Namespace: PushTechnology.ClientInterface.Client.Features.Topics
Assembly: Diffusion.Client.dll
Syntax
public class DefaultSubscriberStream : DefaultStream, ISubscriberStream, IStream, ICallback
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.

Declaration
public virtual void OnSubscription(string topicPath, ITopicSpecification specification)
Parameters
Type Name Description
System.String topicPath

The full topic path.

ITopicSpecification specification

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.

Declaration
public virtual void OnUnsubscription(string topicPath, ITopicSpecification specification, TopicUnsubscribeReason reason)
Parameters
Type Name Description
System.String topicPath

The full topic path.

ITopicSpecification specification

The topic specification.

TopicUnsubscribeReason reason

The reason for unsubscription.

Implements

ISubscriberStream
IStream
ICallback
Back to top