| Modifier and Type | Method and Description |
|---|---|
PipeSource |
AbstractPipeProcessor.getSource()
Gets the value of
AbstractPipeProcessor.source. |
(package private) static <T> PipeSource<T> |
PipeSource.of(Iterator<T> source)
Creates a new instance of
PipeSource with the given
source. |
| Modifier and Type | Method and Description |
|---|---|
protected void |
PipeEnumerator.dequeueSourceProcessors(PipeSource removed)
Removes the processors of the given
PipeSource from
the pipeline. |
void |
AbstractPipeProcessor.setSource(PipeSource reference)
Sets the value of
AbstractPipeProcessor.source. |
Copyright © 2016. All rights reserved.