Package com.pushtechnology.diffusion.client.features

Class Topics.ValueStream.Default<V>

java.lang.Object

com.pushtechnology.diffusion.client.callbacks.Callback.Default

com.pushtechnology.diffusion.client.callbacks.Stream.Default

com.pushtechnology.diffusion.client.features.Topics.SubscriberStream.Default

com.pushtechnology.diffusion.client.features.Topics.ValueStream.Default<V>

Type Parameters:

V - the value class

All Implemented Interfaces:

Callback, Stream, Topics.SubscriberStream, Topics.ValueStream<V>

Enclosing interface:

Topics.ValueStream<V>

public static class Topics.ValueStream.Default<V>
extends Topics.SubscriberStream.Default
implements Topics.ValueStream<V>

Default 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.

Nested Class Summary

Nested classes/interfaces inherited from interface com.pushtechnology.diffusion.client.callbacks.Callback

Callback.Default

Nested classes/interfaces inherited from interface com.pushtechnology.diffusion.client.callbacks.Stream

Stream.Default

Nested classes/interfaces inherited from interface com.pushtechnology.diffusion.client.features.Topics.SubscriberStream

Topics.SubscriberStream.Default

Nested classes/interfaces inherited from interface com.pushtechnology.diffusion.client.features.Topics.ValueStream

Topics.ValueStream.Default<V>

Constructor Summary

Constructors

Constructor	Description
Default()

Method Summary

Modifier and Type	Method	Description
void	onValue(String topicPath, TopicSpecification specification, V oldValue, V newValue)	Notifies an update to a topic value from the server.

Methods inherited from class com.pushtechnology.diffusion.client.features.Topics.SubscriberStream.Default

onSubscription, onUnsubscription

Methods inherited from class com.pushtechnology.diffusion.client.callbacks.Stream.Default

onClose

Methods inherited from class com.pushtechnology.diffusion.client.callbacks.Callback.Default

onError

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.pushtechnology.diffusion.client.callbacks.Callback

onError

Methods inherited from interface com.pushtechnology.diffusion.client.callbacks.Stream

onClose

Methods inherited from interface com.pushtechnology.diffusion.client.features.Topics.SubscriberStream

onSubscription, onUnsubscription

Constructor Details

Default

public Default()

Method Details

onValue

public void onValue(String topicPath,
 TopicSpecification specification,
 V oldValue,
 V newValue)

Description copied from interface: Topics.ValueStream

Notifies an update to a topic value from the server.

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.

Specified by:

onValue in interface Topics.ValueStream<V>

Parameters:

topicPath - the topic path

specification - the topic specification

oldValue - 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.