teetime.stage

Class InitialElementProducer<T>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<T>

teetime.stage.InitialElementProducer<T>

Type Parameters:

T - the type of the elements

public class InitialElementProducer<T>
extends AbstractProducerStage<T>

Represents a producer stage which outputs all of its elements in the first and only execution.

Author:

Christian Wulf

See Also:

ResponsiveProducer

Field Summary

Fields inherited from class teetime.framework.AbstractProducerStage

outputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
InitialElementProducer(Collection<T> elements)
InitialElementProducer(T... elements)

Method Summary

Modifier and Type	Method and Description
protected void	execute() Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
Collection<T>	getElements()

Methods inherited from class teetime.framework.AbstractProducerStage

getOutputPort, getTerminationStrategy

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted

Methods inherited from class java.lang.Object

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

Constructor Detail

InitialElementProducer

@SafeVarargs
public InitialElementProducer(T... elements)

InitialElementProducer

public InitialElementProducer(Collection<T> elements)

Method Detail

execute

protected void execute()

Description copied from class: AbstractStage

Contains the logic of this stage and is invoked (possibly multiple times) by the framework.

Specified by:

execute in class AbstractStage

getElements

public Collection<T> getElements()

Returns:

the elements which should be sent.