Uses of Class
neqsim.process.streaming.TimestampedValue

Packages that use TimestampedValue

Package	Description
neqsim.process.streaming

Uses of TimestampedValue in neqsim.process.streaming

Fields in neqsim.process.streaming with type parameters of type TimestampedValue

Modifier and Type	Field	Description
private final Map<String, TimestampedValue>	ProcessDataPublisher.currentValues
private final Map<String, LinkedList<TimestampedValue>>	ProcessDataPublisher.history
private final Map<String, List<Consumer<TimestampedValue>>>	ProcessDataPublisher.subscribers

Methods in neqsim.process.streaming that return TimestampedValue

Modifier and Type	Method	Description
TimestampedValue	ProcessDataPublisher.getCurrentValue(String tagId)
TimestampedValue	StreamingDataInterface.getCurrentValue(String tagId)	Get the current value for a tag.
static TimestampedValue	TimestampedValue.simulated(double value, String unit)	Creates a new TimestampedValue marked as simulated.

Methods in neqsim.process.streaming that return types with arguments of type TimestampedValue

Modifier and Type	Method	Description
List<TimestampedValue>	ProcessDataPublisher.getHistory(String tagId, Duration lookback)
List<TimestampedValue>	StreamingDataInterface.getHistory(String tagId, Duration lookback)	Get historical values for a tag.
Map<String, List<TimestampedValue>>	ProcessDataPublisher.getHistoryBatch(List<String> tagIds, Duration lookback)
Map<String, List<TimestampedValue>>	StreamingDataInterface.getHistoryBatch(List<String> tagIds, Duration lookback)	Get historical values for multiple tags aligned by timestamp.

Methods in neqsim.process.streaming with parameters of type TimestampedValue

Modifier and Type	Method	Description
default void	StreamingDataInterface.publish(String tagId, TimestampedValue value)	Publish a single value for a tag.

Method parameters in neqsim.process.streaming with type arguments of type TimestampedValue

Modifier and Type	Method	Description
void	ProcessDataPublisher.publishBatch(Map<String, TimestampedValue> values)
void	StreamingDataInterface.publishBatch(Map<String, TimestampedValue> values)	Publish a batch of values for multiple tags efficiently.
void	ProcessDataPublisher.subscribeToUpdates(String tagId, Consumer<TimestampedValue> callback)
void	StreamingDataInterface.subscribeToUpdates(String tagId, Consumer<TimestampedValue> callback)	Subscribe to real-time updates for a specific tag.