Package | Description |
---|---|
com.pushtechnology.diffusion.client.features |
Client API : Standard Features.
|
Modifier and Type | Class and Description |
---|---|
static class |
Topics.ValueStream.Default<V>
Default
Topics.ValueStream implementation. |
Modifier and Type | Method and Description |
---|---|
<V> void |
Topics.addFallbackStream(Class<? extends V> valueClass,
Topics.ValueStream<V> stream)
Add a fallback stream.
|
<V> void |
Topics.addStream(String topics,
Class<? extends V> valueClass,
Topics.ValueStream<V> stream)
Add a value stream to receive topic events for topics that match a given
TopicSelector expression and have a value class that matches a
specified type. |
<V> void |
Topics.addStream(TopicSelector topics,
Class<? extends V> valueClass,
Topics.ValueStream<V> stream)
Add a value stream to receive topic events for topics that match a given
TopicSelector and have a value class that matches a specified
type. |
<V> void |
Topics.addTimeSeriesStream(String topics,
Class<? extends V> eventValueClass,
Topics.ValueStream<TimeSeries.Event<V>> stream)
Add a value stream to receive topic events for time series topics that
match a given
TopicSelector expression and have a compatible time
series value class. |
<V> void |
Topics.addTimeSeriesStream(TopicSelector topics,
Class<? extends V> eventValueClass,
Topics.ValueStream<TimeSeries.Event<V>> stream)
Add a value stream to receive topic events for time series topics that
match a given
TopicSelector and have a compatible time series
event value class. |
Copyright © 2022 Push Technology Ltd. All Rights Reserved.