quarks.oplet.functional

Class SupplierPeriodicSource<T>

java.lang.Object

quarks.oplet.core.AbstractOplet<java.lang.Void,T>

quarks.oplet.core.Source<T>

quarks.oplet.core.PeriodicSource<T>

quarks.oplet.functional.SupplierPeriodicSource<T>

All Implemented Interfaces:

java.lang.AutoCloseable, java.lang.Runnable, PeriodicMXBean, Oplet<java.lang.Void,T>

public class SupplierPeriodicSource<T>
extends PeriodicSource<T>

Constructor Summary

Constructors

Constructor and Description
SupplierPeriodicSource(long period, java.util.concurrent.TimeUnit unit, Supplier<T> data)

Method Summary

Modifier and Type	Method and Description
void	close()
void	fetchTuples()
void	initialize(OpletContext<java.lang.Void,T> context) Initialize the oplet.

Methods inherited from class quarks.oplet.core.PeriodicSource

getPeriod, getRunnable, getUnit, run, setPeriod, start

Methods inherited from class quarks.oplet.core.Source

getDestination, getInputs, submit

Methods inherited from class quarks.oplet.core.AbstractOplet

getOpletContext

Methods inherited from class java.lang.Object

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

Constructor Detail

SupplierPeriodicSource

public SupplierPeriodicSource(long period,
                              java.util.concurrent.TimeUnit unit,
                              Supplier<T> data)

Method Detail

initialize

public void initialize(OpletContext<java.lang.Void,T> context)

Description copied from interface: Oplet

Initialize the oplet.

Specified by:

initialize in interface Oplet<java.lang.Void,T>

Overrides:

initialize in class PeriodicSource<T>

close

public void close()
           throws java.lang.Exception

Throws:

java.lang.Exception

fetchTuples

public void fetchTuples()

Specified by:

fetchTuples in class PeriodicSource<T>