org.diirt.datasource

Interface Collector<I,O>

Type Parameters:

I - the type written in the collector

O - the type read from the collector

All Superinterfaces:

ReadFunction<O>, WriteFunction<I>

All Known Implementing Classes:

CacheCollector, LatestValueCollector, QueueCollector

public interface Collector<I,O>
extends WriteFunction<I>, ReadFunction<O>

A collector can be written from one thread and read from another and provides the point where two subsystems and their rate can be decoupled.

Author:

carcassi

Method Summary

Modifier and Type	Method and Description
void	setChangeNotification(Runnable notification) Task to run to notify of the presence of a new value in the collector.

Methods inherited from interface org.diirt.datasource.WriteFunction

writeValue

Methods inherited from interface org.diirt.datasource.ReadFunction

readValue

Method Detail

setChangeNotification

void setChangeNotification(Runnable notification)

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

Parameters:

notification - callback for the notification