Package com.puresoltechnologies.streaming.iterators

Class StreamIteratorPipe<T>

java.lang.Object

com.puresoltechnologies.streaming.iterators.AbstractStreamIterator<T>

com.puresoltechnologies.streaming.iterators.StreamIteratorPipe<T>

All Implemented Interfaces:

StreamIterator<T>, Closeable, AutoCloseable, Iterator<T>

public class StreamIteratorPipe<T>
extends AbstractStreamIterator<T>
implements Closeable

Constructor Summary

Constructors

Constructor	Description
StreamIteratorPipe()
StreamIteratorPipe(int capacity)

Method Summary

Modifier and Type	Method	Description
void	close()
protected T	findNext()	This method looks for the next entry to be returned.
void	push(T element)

Methods inherited from class com.puresoltechnologies.streaming.iterators.AbstractStreamIterator

hasNext, next, peek

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.puresoltechnologies.streaming.iterators.StreamIterator

empty, filter, flatMap, map, of, spliterator, stream

Constructor Detail

StreamIteratorPipe

public StreamIteratorPipe()

StreamIteratorPipe

public StreamIteratorPipe(int capacity)

Method Detail

push

public void push(T element)
          throws InterruptedException

Throws:

InterruptedException

findNext

protected T findNext()

Description copied from class: AbstractStreamIterator

This method looks for the next entry to be returned. If no further entry is found, null is returned.

Specified by:

findNext in class AbstractStreamIterator<T>

Returns:

An object of T is returned representing the next entry to be returned by the iterator. null is returned in case no more entries are available.

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException