org.diirt.datasource

Class LatestValueCollector<T>

java.lang.Object

org.diirt.datasource.LatestValueCollector<T>

Type Parameters:

T - the type stored in the collector

All Implemented Interfaces:

Collector<T,T>, ReadFunction<T>, WriteFunction<T>

public class LatestValueCollector<T>
extends Object
implements Collector<T,T>

A collector that keeps only the latest value.

Author:

carcassi

Constructor Summary

Constructors

Constructor and Description
LatestValueCollector()

Method Summary

Modifier and Type	Method and Description
T	readValue() Calculates, if needed, and then returns the value for this function.
void	setChangeNotification(Runnable notification) Task to run to notify of the presence of a new value in the collector.
void	writeValue(T newValue) Takes the value and consumes it.

Methods inherited from class java.lang.Object

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

Constructor Detail

LatestValueCollector

public LatestValueCollector()

Method Detail

writeValue

public void writeValue(T newValue)

Description copied from interface: WriteFunction

Takes the value and consumes it.

Specified by:

writeValue in interface WriteFunction<T>

Parameters:

newValue - a value

readValue

public T readValue()

Description copied from interface: ReadFunction

Calculates, if needed, and then returns the value for this function.

Specified by:

readValue in interface ReadFunction<T>

Returns:

a value

setChangeNotification

public void setChangeNotification(Runnable notification)

Description copied from interface: Collector

Task to run to notify of the presence of a new value in the collector.

Specified by:

setChangeNotification in interface Collector<T,T>

Parameters:

notification - callback for the notification