com.aol.cyclops2.internal.react.stream

Class Runner<U>

java.lang.Object

com.aol.cyclops2.internal.react.stream.Runner<U>

public class Runner<U>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Runner()

Method Summary

Modifier and Type	Method and Description
boolean	run(LazyStreamWrapper<U> lastActive, EmptyCollector<U> collector)
Continuation	runContinuations(LazyStreamWrapper lastActive, EmptyCollector collector)

Methods inherited from class java.lang.Object

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

Constructor Detail

Runner

public Runner()

Method Detail

run

public boolean run(LazyStreamWrapper<U> lastActive,
                   EmptyCollector<U> collector)

runContinuations

public Continuation runContinuations(LazyStreamWrapper lastActive,
                                     EmptyCollector collector)