V
- the value classpublic static class Topics.ValueStream.Default<V> extends Topics.SubscriberStream.Default implements Topics.ValueStream<V>
Topics.ValueStream
implementation.
This logs all calls at 'debug' level. These implementations can be useful during development but are usually overridden to provide meaningful processing.
Topics.ValueStream.Default<V>
Constructor and Description |
---|
Default() |
Modifier and Type | Method and Description |
---|---|
void |
onValue(String topicPath,
TopicSpecification specification,
V oldValue,
V newValue)
Notifies an update to a topic value from the server.
|
onSubscription, onUnsubscription
onClose
onError
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onSubscription, onUnsubscription
public void onValue(String topicPath, TopicSpecification specification, V oldValue, V newValue)
Topics.ValueStream
This is also called to provide the current value for any matching topic that the session is already subscribed to when the stream is added.
onValue
in interface Topics.ValueStream<V>
topicPath
- the topic pathspecification
- the topic specificationoldValue
- the previous value. Will be null for the initial call
to onValue for a topic. It can also be null if the topic's
data type supports null values.newValue
- the new value derived from the last update received
from the server. It can be null if the topic's data type
supports null values.Copyright © 2024 DiffusionData Ltd. All Rights Reserved.