org.apache.beam.sdk.fn.stream

Class DataStreams.BlockingQueueIterator<T>

java.lang.Object

org.apache.beam.sdk.fn.stream.DataStreams.BlockingQueueIterator<T>

All Implemented Interfaces:

java.lang.AutoCloseable, java.util.Iterator<T>

Enclosing class:

DataStreams

public static class DataStreams.BlockingQueueIterator<T>
extends java.lang.Object
implements java.lang.AutoCloseable, java.util.Iterator<T>

Allows for one or more writing threads to append values to this iterator while one reading thread reads values. hasNext() and next() will block until a value is available or this has been closed.

External synchronization must be provided if multiple readers would like to access the Iterator.hasNext() and Iterator.next() methods.

The order or values which are appended to this iterator is nondeterministic when multiple threads call accept(Object).

Constructor Summary

Constructors

Constructor and Description
BlockingQueueIterator(java.util.concurrent.BlockingQueue<T> queue)

Method Summary

Modifier and Type	Method and Description
void	accept(T t)
void	close()
boolean	hasNext()
T	next()
void	remove()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

BlockingQueueIterator

public BlockingQueueIterator(java.util.concurrent.BlockingQueue<T> queue)

Method Detail

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

accept

public void accept(T t)
            throws java.lang.Exception

Throws:

java.lang.Exception

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<T>

next

public T next()

Specified by:

next in interface java.util.Iterator<T>

remove

public void remove()

Specified by:

remove in interface java.util.Iterator<T>