|
Groovy Documentation | |||||||
FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | PROPERTY | CONSTR | METHOD | DETAIL: FIELD | PROPERTY | CONSTR | METHOD |
java.lang.Objectgroovyx.gpars.actor.AbstractPooledActor
gpars.dataflow.operator.DataFlowOperatorActor
class DataFlowOperatorActor extends AbstractPooledActor
An operator's internal actor. Repeatedly polls inputs and once they're all available it performs the operator's body.
Property Summary | |
---|---|
groovy.lang.Closure |
code
|
List |
inputs
|
List |
outputs
|
def |
owningOperator
|
Constructor Summary | |
DataFlowOperatorActor(def owningOperator, def outputs, def inputs, def code)
|
Method Summary | |
---|---|
protected void
|
act()
|
void
|
handleValueMessage(Map values, def count)
Calls itself recursively within a react() call, if more input values are still needed. |
def
|
reportException(Throwable e)
|
def
|
startTask(def results)
|
Property Detail |
---|
final groovy.lang.Closure code
final List inputs
final List outputs
final def owningOperator
Constructor Detail |
---|
public DataFlowOperatorActor(def owningOperator, def outputs, def inputs, def code)
Method Detail |
---|
protected final void act()
public final void handleValueMessage(Map values, def count)
public final def reportException(Throwable e)
public def startTask(def results)
Groovy Documentation