Field Detail

• protected final DataflowVariable<T> first

• protected final java.util.concurrent.atomic.AtomicReference<StreamCore<T>> rest

• protected final java.util.Collection<MessageStream> wheneverBoundListeners

  A collection of listeners who need to be informed each time the stream is bound to a value

Constructor Detail

• protected StreamCore(DataflowVariable<T> first)

  Creates an empty stream

  Parameters:

  first - The variable to store as the head of the stream

• protected StreamCore(DataflowVariable<T> first, groovy.lang.Closure toBeApplied)

  Creates a stream while applying the supplied initialization closure to it

  Parameters:

  first - The variable to store as the head of the stream

  toBeApplied - The closure to use for initialization

• @java.lang.SuppressWarnings({"AssignmentToCollectionOrArrayFieldFromParameter"}) protected StreamCore(DataflowVariable<T> first, java.util.Collection<MessageStream> wheneverBoundListeners, java.util.Collection<DataflowChannelListener<T>> updateListeners)

Method Detail

• final void addUpdateListener(DataflowChannelListener<T> updateListener)

• private void addUpdateListeners(java.util.Collection<DataflowChannelListener<T>> updateListeners)

• @java.lang.Override public java.lang.String appendingString()

• public final StreamCore<T> apply(groovy.lang.Closure closure)

  Calls the supplied closure with the stream as a parameter

  Returns:

  This instance of DataflowStream

  Parameters:

  closure - The closure to call

• private void bind(T value)

• protected StreamCore<T> createNewStream()

  A factory method to create new instances of the correct class when needed

  Returns:

  An instance of the appropriate sub-class

• public void decrementParties()

  Decreases the number of parties required to perform the data exchange

• public static T eos()

• @java.lang.Override public boolean equals(java.lang.Object obj)

• private static T eval(java.lang.Object valueOrDataflowVariable)

• @java.lang.Override public final FList<T> filter(groovy.lang.Closure filterClosure)

  Builds a filtered stream using the supplied filter closure

  Returns:

  The first item of the filtered stream

  Parameters:

  filterClosure - The closure to decide on inclusion of elements

• private void filter(StreamCore<T> rest, groovy.lang.Closure filterClosure, StreamCore<T> result)

• public final StreamCore<T> generate(T seed, groovy.lang.Closure generator, groovy.lang.Closure condition)

  Populates the stream with generated values

  Returns:

  This stream

  Parameters:

  seed - The initial element to evaluate and add as the first value of the stream

  generator - A closure generating stream elements from the previous values

  condition - A closure indicating whether the generation should continue based on the last generated value

• private void generateNext(T value, StreamCore<T> stream, groovy.lang.Closure generator, groovy.lang.Closure condition)

• @java.lang.Override public final T getFirst()

  Retrieved the first element in the stream, blocking until a value is available

  Returns:

  The first item in the stream

• final DataflowVariable<T> getFirstDFV()

• @java.lang.Override public FList<T> getRest()

  Retrieves a DataflowStream representing the rest of this Stream after removing the first element

  Returns:

  The remaining stream elements

• @java.lang.Override public int hashCode()

• private DataflowExpression<T> hookWheneverBoundListeners(DataflowExpression<T> expr)

  Hooks the registered when bound handlers to the supplied dataflow expression

  Returns:

  The supplied expression handler to allow method chaining

  Parameters:

  expr - The expression to hook all the when bound listeners to

• public void incrementParties()

  Increases the number of parties required to perform the data exchange

• @java.lang.Override public final boolean isEmpty()

  Indicates, whether the first element in the stream is an eos

• @java.lang.Override public final java.util.Iterator<T> iterator()

  Builds an iterator to iterate over the stream

  Returns:

  A new FListIterator instance

• public final StreamCore<T> leftShift(DataflowReadChannel<T> ref)

  Adds a dataflow variable value to the stream, once the value is available

  Returns:

  The rest of the stream

  Parameters:

  ref - The DataflowVariable to check for value

• public final StreamCore<T> leftShift(T value)

  Adds a value to the stream

  Returns:

  The rest of the stream

  Parameters:

  value - The value to add

• @java.lang.Override public final FList<java.lang.Object> map(groovy.lang.Closure mapClosure)

  Builds a modified stream using the supplied map closure

  Returns:

  The first item of the transformed stream

  Parameters:

  mapClosure - The closure to transform elements

• private void map(FList<T> rest, groovy.lang.Closure mapClosure, StreamCore<java.lang.Object> result)

• @java.lang.Override public final T reduce(groovy.lang.Closure reduceClosure)

  Reduces all elements in the stream using the supplied closure

  Returns:

  The result of reduction of the whole stream

  Parameters:

  reduceClosure - The closure to reduce elements of the stream gradually into an accumulator. The accumulator is seeded with the first stream element.

• @java.lang.Override public final T reduce(T seed, groovy.lang.Closure reduceClosure)

  Reduces all elements in the stream using the supplied closure

  Returns:

  The result of reduction of the whole stream

  Parameters:

  reduceClosure - The closure to reduce elements of the stream gradually into an accumulator.

  seed - The value to initialize the accumulator with.

• private T reduce(T current, FList<T> rest, groovy.lang.Closure reduceClosure)

• public final void wheneverBound(groovy.lang.Closure closure)

• public final void wheneverBound(MessageStream stream)