Groovy Documentation

gpars.dataflow.operator
Class DataFlowOperatorActor

java.lang.Object
  groovyx.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

code

final groovy.lang.Closure code


inputs

final List inputs


outputs

final List outputs


owningOperator

final def owningOperator


 
Constructor Detail

DataFlowOperatorActor

public DataFlowOperatorActor(def owningOperator, def outputs, def inputs, def code)


 
Method Detail

act

protected final void act()


handleValueMessage

public final void handleValueMessage(Map values, def count)
Calls itself recursively within a react() call, if more input values are still needed. Once all required inputs are available (received as messages), the operator's body is run.


reportException

public final def reportException(Throwable e)


startTask

public def startTask(def results)


 

Groovy Documentation