Overview  Package   Class  Deprecated  Index  Help 
Groovy Documentation
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | PROPERTY | CONSTR | METHOD DETAIL: FIELD | PROPERTY | CONSTR | METHOD

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