Uses of Class
enumj.AbstractPipeProcessor

Uses of AbstractPipeProcessor in enumj

Subclasses of AbstractPipeProcessor in enumj

Modifier and Type	Class and Description
(package private) class	AbstractPipeMultiProcessor<T,R> Pipe processor that may produce multiple output elements for an input element.
(package private) class	FilterPipeProcessor<E> Pipe processor that knows how to filter elements in the pipeline.
(package private) class	FlatMapPipeProcessor<In,Out> Pipe processor that flattens sub-iterators generated by mapping enumerated elements.
(package private) class	LimitPipeProcessor<E> Pipe processor that stops enumeration once a limit is reached.
(package private) class	MapPipeProcessor<In,Out> Pipe processor that transforms inputs elements by mapping them to output elements.
(package private) class	SkipPipeProcessor<E> Pipe processor that skips over a number of elements.
(package private) class	SkipWhilePipeProcessor<E> Pipe processor that skips over enumerated elements as long as a condition holds true.
(package private) class	WhilePipeProcessor<E> Pipe processor that lets enumeration through as long as a predicate holds true.
(package private) class	ZipPipeProcessor<E> Pipe processor that zips enumerated values together.

Methods in enumj that return AbstractPipeProcessor

Modifier and Type	Method and Description
protected AbstractPipeProcessor	PipeEnumerator.dequeueProcessor() Removes the element in front of pipeline and returns the new head of pipeline.
AbstractPipeProcessor<?,?>	PipeSource.getFirstProcessor() Gets the first AbstractPipeProcessor instance that processes the elements of this PipeSource.
AbstractPipeProcessor<? extends R,?>	AbstractPipeProcessor.getNext() Returns the value of AbstractPipeProcessor.next.

Methods in enumj with parameters of type AbstractPipeProcessor

Modifier and Type	Method and Description
protected void	PipeEnumerator.dequeueSourcesUpToProcessor(AbstractPipeProcessor processor) Removes the front elements of PipeEnumerator.sources until the given AbstractPipeProcessor becomes first in pipeline.
protected <X> Enumerator<X>	PipeEnumerator.enqueueProcessor(AbstractPipeProcessor<? super E,? extends X> processor) Adds the given processor to the back of the pipeline.
protected <X> PipeEnumerator<E>	PipeEnumerator.pushFrontProcessor(AbstractPipeProcessor<? super X,?> processor) Adds the given processor to the front of the pipeline.
protected <X> void	PipeEnumerator.safePipelineAddFirst(AbstractPipeProcessor<? super X,?> processor) Adds the given processor at the front of pipeline.
protected <X> void	PipeEnumerator.safePipelineAddLast(AbstractPipeProcessor<? super E,? extends X> processor) Adds the given processor to the end of pipeline.
void	PipeSource.setFirstProcessorIfNone(AbstractPipeProcessor<?,?> processor) Sets firstProcessor to the given AbstractPipeProcessor if there is none.
void	AbstractPipeProcessor.setNext(AbstractPipeProcessor<? extends R,?> next) Sets the value of AbstractPipeProcessor.next.
protected boolean	PipeEnumerator.tryPipelineOut(Object in, AbstractPipeProcessor processor, Out<Boolean> nextOnSameSourceOnNoValue) Tries to process the given in value through the pipeline and produce an output in value.

Method parameters in enumj with type arguments of type AbstractPipeProcessor

Modifier and Type	Method and Description
protected boolean	PipeEnumerator.tryPipelineIn(Out<Object> in, Out<AbstractPipeProcessor> processor) Tries to obtain obtain an input value for the pipeline.