enumj

Class PipeSource<E>

java.lang.Object

enumj.AbstractEnumerator<E>

enumj.IteratorEnumerator<E>

enumj.PipeSource<E>

Type Parameters:

E - type of enumerated elements.

All Implemented Interfaces:

Enumerator<E>, Iterator<E>

final class PipeSource<E>
extends IteratorEnumerator<E>

IteratorEnumerator that acts as a source of enumerated elements for AbstractPipeProcessor instances within PipeEnumerator.pipeline.

See Also:

IteratorEnumerator, PipeEnumerator, PipeEnumerator.pipeline, AbstractPipeProcessor

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PipeSource(Iterator<E> source) Constructs a new PipeSource instances based on the given source.

Method Summary

Modifier and Type	Method and Description
AbstractPipeProcessor<?,?>	getFirstProcessor() Gets the first AbstractPipeProcessor instance that processes the elements of this PipeSource.
(package private) static <T> PipeSource<T>	of(Iterator<T> source) Creates a new instance of PipeSource with the given source.
void	setFirstProcessorIfNone(AbstractPipeProcessor<?,?> processor) Sets firstProcessor to the given AbstractPipeProcessor if there is none.

Methods inherited from class enumj.IteratorEnumerator

cleanup, internalHasNext, internalNext

Methods inherited from class enumj.AbstractEnumerator

enumerating, hasNext, next

Methods inherited from class java.lang.Object

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

Methods inherited from interface enumj.Enumerator

allMatch, anyMatch, append, as, asEnumerable, asEnumeration, asFiltered, asOptional, asShareable, asSpliterator, asStream, asSupplier, asTolerant, asTolerant, choiceOf, choiceOf, collect, concat, concat, concat, concat, concat, concat, concatOn, contains, count, distinct, elementAt, elementsEqual, empty, filter, first, flatMap, forEach, iterate, last, limit, limitWhile, map, map, max, min, noneMatch, of, of, of, of, of, of, of, ofLateBinding, ofLazyEnumeration, ofLazyIterable, ofLazyIterator, ofLazySpliterator, ofLazyStream, on, peek, prepend, prepend, prepend, prepend, prepend, prepend, prependOn, range, rangeClosed, rangeInt, rangeIntClosed, rangeLong, rangeLongClosed, reduce, reduce, repeat, repeatAll, repeatAll, repeatEach, reverse, single, skip, skipWhile, sorted, sorted, take, takeWhile, toArray, toList, toMap, toSet, union, union, union, union, union, union, unionOn, zipAll, zipAny, zipBoth, zipLeft, zipRight

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

PipeSource

protected PipeSource(Iterator<E> source)

Constructs a new PipeSource instances based on the given source.

Parameters:

source - Iterator supplying enumerated elements.

See Also:

PipeSource

Method Detail

getFirstProcessor

public AbstractPipeProcessor<?,?> getFirstProcessor()

Gets the first AbstractPipeProcessor instance that processes the elements of this PipeSource.

Returns:

AbstractPipeProcessor instance.

setFirstProcessorIfNone

public void setFirstProcessorIfNone(AbstractPipeProcessor<?,?> processor)

Sets firstProcessor to the given AbstractPipeProcessor if there is none.

Parameters:

processor - value for firstProcessor if none.

of

static <T> PipeSource<T> of(Iterator<T> source)

Creates a new instance of PipeSource with the given source.

Type Parameters:

T - type of enumerated elements.

Parameters:

source - Iterator instance acting as a source of elements.

Returns:

PipeSource instance.