io.druid.java.util.common.guava

Class ExecuteWhenDoneYielder<T>

java.lang.Object

io.druid.java.util.common.guava.ExecuteWhenDoneYielder<T>

All Implemented Interfaces:

Yielder<T>, Closeable, AutoCloseable

public class ExecuteWhenDoneYielder<T>
extends Object
implements Yielder<T>

Constructor Summary

Constructors

Constructor and Description
ExecuteWhenDoneYielder(Yielder<T> baseYielder, Runnable runnable, Executor executor)

Method Summary

Modifier and Type	Method and Description
void	close()
T	get() Gets the object currently held by this Yielder.
boolean	isDone() Returns true if this is the last Yielder in the chain.
Yielder<T>	next(T initValue) Gets the next Yielder in the chain.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecuteWhenDoneYielder

public ExecuteWhenDoneYielder(Yielder<T> baseYielder,
                              Runnable runnable,
                              Executor executor)

Method Detail

get

public T get()

Description copied from interface: Yielder

Gets the object currently held by this Yielder. Can be called multiple times as long as next() is not called. Once next() is called on this Yielder object, all further operations on this object are undefined.

Specified by:

get in interface Yielder<T>

Returns:

the currently yielded object, null if done

next

public Yielder<T> next(T initValue)

Description copied from interface: Yielder

Gets the next Yielder in the chain. The argument is used as the accumulator value to pass along to start the accumulation until the next yield() call or iteration completes. Once next() is called on this Yielder object, all further operations on this object are undefined.

Specified by:

next in interface Yielder<T>

Parameters:

initValue - the initial value to pass along to start the accumulation until the next yield() call or iteration completes.

Returns:

the next Yielder in the chain, or undefined if done

isDone

public boolean isDone()

Description copied from interface: Yielder

Returns true if this is the last Yielder in the chain. A Yielder that isDone() may return anything from both get() and next(), there is no contract and depending on those return values will likely lead to bugs. It will probably break your code to call next() on a Yielder that is done and expect something good from it. Once next() is called on this Yielder object, all further operations on this object are undefined.

Specified by:

isDone in interface Yielder<T>

Returns:

true if this is the last Yielder in the chain, false otherwise

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException