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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
Method Detail
-
initialize
public void initialize(OpletContext<java.lang.Void,T> context)
Description copied from interface:Oplet
Initialize the oplet.- Specified by:
initialize
in interfaceOplet<java.lang.Void,T>
- Overrides:
initialize
in classPeriodicSource<T>
-
close
public void close() throws java.lang.Exception
- Throws:
java.lang.Exception
-
fetchTuples
public void fetchTuples()
- Specified by:
fetchTuples
in classPeriodicSource<T>
-
-