Method Detail

• @java.lang.SuppressWarnings({"ClassReferencesSubclass"}) public DataflowExpression<T> poll()

  Retrieves the value at the head of the buffer. Returns null, if no value is available.

  throws:

  InterruptedException If the current thread is interrupted

  Returns:

  The value bound to the DFV at the head of the stream or null

• public void wheneverBound(groovy.lang.Closure<V> closure)

  Send all pieces of data bound in the future to the provided stream when it becomes available. *

  Parameters:

  closure - closure to execute when data becomes available. The closure should take at most one argument.

• public void wheneverBound(MessageStream stream)

  Send all pieces of data bound in the future to the provided stream when it becomes available.

  Parameters:

  stream - stream where to send result