enumj

Class AbstractPipeMultiProcessor<T,R>

java.lang.Object

enumj.AbstractPipeProcessor<T,R>

enumj.AbstractPipeMultiProcessor<T,R>

Type Parameters:

T - Type of input element.

R - Type of resulted elements.

Direct Known Subclasses:

FlatMapPipeProcessor

abstract class AbstractPipeMultiProcessor<T,R>
extends AbstractPipeProcessor<T,R>

Pipe processor that may produce multiple output elements for an input element.

See Also:

AbstractPipeProcessor, PipeEnumerator

Field Summary

Fields inherited from class enumj.AbstractPipeProcessor

hasNextNeedsValue, nextOnSameSourceOnNoValue

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractPipeMultiProcessor(boolean nextOnSameSourceOnNoValue, boolean hasNextNeedsValue) Constructs a new AbstractPipeMultiProcessor instance.

Method Summary

Modifier and Type	Method and Description
abstract boolean	needsValue() Gets whether the processor needs a fresh input value to produce output values.

Methods inherited from class enumj.AbstractPipeProcessor

clearOutputValue, enqueueFilter, enqueueMap, getNext, getOutputValue, getSource, hasOutputValue, isInactive, processInputValue, pushFrontFilter, pushFrontMap, retrieveOutputValue, setNext, setSource

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractPipeMultiProcessor

protected AbstractPipeMultiProcessor(boolean nextOnSameSourceOnNoValue,
                                     boolean hasNextNeedsValue)

Constructs a new AbstractPipeMultiProcessor instance.

Parameters:

nextOnSameSourceOnNoValue - value for AbstractPipeProcessor.nextOnSameSourceOnNoValue.

hasNextNeedsValue - value for AbstractPipeProcessor.hasNextNeedsValue.

See Also:

AbstractPipeProcessor

Method Detail

needsValue

public abstract boolean needsValue()

Gets whether the processor needs a fresh input value to produce output values.

Unlike AbstractPipeProcessor, this type of processor may yield more than one output for a single input. This means feeding in input values must be put on hold as long as the current processor still has output values to provide. This state ends when needsValue returns true.

Returns:

true if the processor needs a new input to produce outputs, false otherwise.

See Also:

AbstractPipeProcessor