public static interface Topics.SubscriberStream extends Stream
See Topics.ValueStream
and Topics
class documentation for
further details of the use of subscriber streams.
Modifier and Type | Interface and Description |
---|---|
static class |
Topics.SubscriberStream.Default
Default
Topics.SubscriberStream implementation. |
Modifier and Type | Method and Description |
---|---|
void |
onSubscription(String topicPath,
TopicSpecification specification)
Subscription notification.
|
void |
onUnsubscription(String topicPath,
TopicSpecification specification,
Topics.UnsubscribeReason reason)
Unsubscription notification.
|
void onSubscription(String topicPath, TopicSpecification specification)
This method is called when a session is subscribed to a topic that matches the stream registration. This method is also called when a stream is added, for all of the session's subscriptions to topics that match the stream registration.
For a given topic, onSubscription
will be the initial
notification, and the first notification following an
unsubscription
notification if the session
re-subscribes to the topic.
This method is also called for fallback streams that match the topic type when the session removes the last stream that selected a subscribed topic. The fallback stream will now receive updates for the topic, starting with an immediate notification of the currently cached value (if any).
topicPath
- the topic pathspecification
- the topic specificationvoid onUnsubscription(String topicPath, TopicSpecification specification, Topics.UnsubscribeReason reason)
This method is called if the session is unsubscribed from a topic that matches the stream registration. The stream will receive no more updates for the topic unless the session re-subscribes to the topic.
This method is also called for fallback streams that match the topic
type if the session
adds
the first
stream that selects a subscribed topic. For these notifications,
reason
will be Topics.UnsubscribeReason.STREAM_CHANGE
. The
fallback stream will no longer receive updates for the topic.
topicPath
- the topic pathspecification
- the topic specificationreason
- the reason for unsubscriptionCopyright © 2024 DiffusionData Ltd. All Rights Reserved.