enumj

Class MapPipeProcessor<In,Out>

java.lang.Object

enumj.AbstractPipeProcessor<In,Out>

enumj.MapPipeProcessor<In,Out>

Type Parameters:

In - input value to map.

Out - mapped output value.

final class MapPipeProcessor<In,Out>
extends AbstractPipeProcessor<In,Out>

Pipe processor that transforms inputs elements by mapping them to output elements.

See Also:

FlatMapPipeProcessor, ZipPipeProcessor

Field Summary

Fields inherited from class enumj.AbstractPipeProcessor

hasNextNeedsValue, nextOnSameSourceOnNoValue

Constructor Summary

Constructors

Constructor and Description
MapPipeProcessor(Function<In,Out> functor) Constructs a MapPipeProcessor instance.

Method Summary

Modifier and Type	Method and Description
protected void	clearOutputValue() Clears the processed result after being returned by AbstractPipeProcessor.retrieveOutputValue().
<R> boolean	enqueueMap(Function<Out,R> mapper) Returns true and aggregates the given mapper to the end of existing mappers, otherwise it returns false.
boolean	hasOutputValue() Gets whether processing was successful and the processor has a value to yield.
boolean	isInactive() Gets whether the processor does not process any more and the pipeline up to it should be discarded.
void	processInputValue(In value) Processes an input value in order to return a result, if any.
<R> boolean	pushFrontMap(Function<Out,R> mapper) Returns true and aggregates the given mapper to the top of the existing mappers, otherwise it returns false.
protected Out	retrieveOutputValue() Retrieves the processed result produced by AbstractPipeProcessor.processInputValue(Object).

Methods inherited from class enumj.AbstractPipeProcessor

enqueueFilter, getNext, getOutputValue, getSource, pushFrontFilter, setNext, setSource

Methods inherited from class java.lang.Object

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

Constructor Detail

MapPipeProcessor

public MapPipeProcessor(Function<In,Out> functor)

Constructs a MapPipeProcessor instance.

The new MapPipeProcessor instance stores its functor internally.

Parameters:

functor - Function mapping input elements to output elements.

Method Detail

pushFrontMap

public <R> boolean pushFrontMap(Function<Out,R> mapper)

Description copied from class: AbstractPipeProcessor

Returns true and aggregates the given mapper to the top of the existing mappers, otherwise it returns false.

This method returns false by default. The only AbstractPipeProcessor capable of mapping aggregation is MapPipeProcessor.

Overrides:

pushFrontMap in class AbstractPipeProcessor<In,Out>

Type Parameters:

R - type of mapped enumerated elements.

Parameters:

mapper - mapping Function.

Returns:

true on successful aggregation of mappers, false otherwise.

enqueueMap

public <R> boolean enqueueMap(Function<Out,R> mapper)

Description copied from class: AbstractPipeProcessor

Returns true and aggregates the given mapper to the end of existing mappers, otherwise it returns false.

This method returns false by default. The only AbstractPipeProcessor capable of mapping aggregation is MapPipeProcessor.

Overrides:

enqueueMap in class AbstractPipeProcessor<In,Out>

Type Parameters:

R - type of mapped enumerated elements.

Parameters:

mapper - mapping Function.

Returns:

true on successful aggregation of mappers, false otherwise.

processInputValue

public void processInputValue(In value)

Description copied from class: AbstractPipeProcessor

Processes an input value in order to return a result, if any.

The result of processing must be stored internally.

Specified by:

processInputValue in class AbstractPipeProcessor<In,Out>

Parameters:

value - Value to process.

See Also:

AbstractPipeProcessor.hasOutputValue(), AbstractPipeProcessor.getOutputValue()

hasOutputValue

public boolean hasOutputValue()

Description copied from class: AbstractPipeProcessor

Gets whether processing was successful and the processor has a value to yield.

If AbstractPipeProcessor.hasOutputValue() returns false than no internal storage of input or output may take place.

Specified by:

hasOutputValue in class AbstractPipeProcessor<In,Out>

Returns:

true if there is an output value to yield, false otherwise.

See Also:

AbstractPipeProcessor.processInputValue(java.lang.Object), AbstractPipeProcessor.getOutputValue()

retrieveOutputValue

protected Out retrieveOutputValue()

Description copied from class: AbstractPipeProcessor

Retrieves the processed result produced by AbstractPipeProcessor.processInputValue(Object).

Specified by:

retrieveOutputValue in class AbstractPipeProcessor<In,Out>

Returns:

Processed result.

See Also:

AbstractPipeProcessor.getOutputValue(), AbstractPipeProcessor.clearOutputValue()

clearOutputValue

protected void clearOutputValue()

Description copied from class: AbstractPipeProcessor

Clears the processed result after being returned by AbstractPipeProcessor.retrieveOutputValue().

Specified by:

clearOutputValue in class AbstractPipeProcessor<In,Out>

See Also:

AbstractPipeProcessor.getOutputValue(), AbstractPipeProcessor.retrieveOutputValue()

isInactive

public boolean isInactive()

Description copied from class: AbstractPipeProcessor

Gets whether the processor does not process any more and the pipeline up to it should be discarded.

AbstractPipeProcessor.isInactive() returning true is equivalent to the situation when no matter with what value AbstractPipeProcessor.processInputValue(Object) will be called, AbstractPipeProcessor.hasOutputValue() will always return false.

Most processors have this function return false with the exception of while and limit compositions. These will turn completely inactive once a certain condition is met.

Specified by:

isInactive in class AbstractPipeProcessor<In,Out>

Returns:

true if processing must stop, false otherwise.