it.cnr.isti.hpc.dexter.spot.cleanpipe

Class Pipe<T>

java.lang.Object

it.cnr.isti.hpc.dexter.spot.cleanpipe.Pipe<T>

public class Pipe<T>
extends Object

Class pipe allows to create a chain of functions manipulating T objects. Pipes are chained together through their constructors.

Author:

Diego Ceccarelli Created on Sep 18, 2013

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	Pipe.OutputCollector

Field Summary

Fields

Modifier and Type	Field and Description
LinkedList<T>	output

Constructor Summary

Constructors

Constructor and Description
Pipe(Function<T> fun)
Pipe(Pipe<T> previous, Function<T> fun)

Method Summary

Methods

Modifier and Type	Method and Description
protected List<T>	getResults()
List<T>	process(T elem) Performs all the pipeline over the object elem, and returns one or multiple manipulations of the object elem.
protected void	pushResult(T elem)

Methods inherited from class java.lang.Object

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

Field Detail

output

public LinkedList<T> output

Constructor Detail

Pipe

public Pipe(Function<T> fun)

Pipe

public Pipe(Pipe<T> previous,
    Function<T> fun)

Method Detail

getResults

protected List<T> getResults()

process

public List<T> process(T elem)

Performs all the pipeline over the object elem, and returns one or multiple manipulations of the object elem.

pushResult

protected void pushResult(T elem)