groovyx.gpars.dataflow.expression

Class DataflowInvocationExpression

java.lang.Object

groovyx.gpars.serial.WithSerialId

groovyx.gpars.dataflow.expression.DataflowExpression<T>

groovyx.gpars.dataflow.expression.DataflowComplexExpression<java.lang.Object>

groovyx.gpars.dataflow.expression.DataflowInvocationExpression

All Implemented Interfaces:

groovy.lang.GroovyObject, DataflowReadChannel<java.lang.Object>, SelectableChannel<java.lang.Object>, java.io.Serializable

public class DataflowInvocationExpression
extends DataflowComplexExpression<java.lang.Object>

A dataflow expression, which invokes a method after the receiver as well as all the arguments become available

Author:

Alex Tkachman

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class groovyx.gpars.dataflow.expression.DataflowExpression

DataflowExpression.BindDataflow<T>, DataflowExpression.DataflowExpressionsCollector

Field Summary

Fields

Modifier and Type	Field and Description
private java.lang.String	methodName
private java.lang.Object	receiver
private static long	serialVersionUID

Fields inherited from class groovyx.gpars.dataflow.expression.DataflowComplexExpression

args

Fields inherited from class groovyx.gpars.dataflow.expression.DataflowExpression

error, S_INITIALIZED, S_INITIALIZING, S_NOT_INITIALIZED, state, stateUpdater, value, waitingUpdater

Fields inherited from class groovyx.gpars.serial.WithSerialId

serialHandle

Constructor Summary

Constructors

Constructor and Description
DataflowInvocationExpression(java.lang.Object receiver, java.lang.String methodName, java.lang.Object[] args)

Method Summary

Modifier and Type	Method and Description
protected java.lang.Object	evaluate() Evaluates all the arguments
protected void	subscribe(DataflowExpression.DataflowExpressionsCollector listener) Subscribes the listener to all the arguments

Methods inherited from class groovyx.gpars.dataflow.expression.DataflowExpression

binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, bind, bindError, bindSafely, bindUnique, chainWith, chainWith, chainWith, chainWith, chainWith, chainWith, choice, choice, choice, choice, choice, choice, doBindImpl, doBindRemote, filter, filter, filter, filter, filter, filter, getBindErrorManager, getEventManager, getMetaClass, getProperty, getVal, getVal, getValAsync, getValAsync, into, into, into, into, into, into, invokeMethod, isBound, join, join, length, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, or, or, poll, rightShift, scheduleCallback, separate, separate, separate, separate, separate, separate, setMetaClass, setProperty, split, split, split, split, split, split, split, split, split, split, split, split, subscribe, tap, tap, tap, tap, tap, tap, then, then, then, thenForkAndJoin, thenForkAndJoin, thenForkAndJoin, toString, transform, whenBound, whenBound, whenBound, whenBound, wheneverBound, wheneverBound

Methods inherited from class groovyx.gpars.serial.WithSerialId

createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

receiver

private java.lang.Object receiver

methodName

private final java.lang.String methodName

Constructor Detail

DataflowInvocationExpression

public DataflowInvocationExpression(java.lang.Object receiver,
                                    java.lang.String methodName,
                                    java.lang.Object[] args)

Method Detail

evaluate

protected java.lang.Object evaluate()

Description copied from class: DataflowComplexExpression

Evaluates all the arguments

Overrides:

evaluate in class DataflowComplexExpression<java.lang.Object>

Returns:

The value to bind

subscribe

protected void subscribe(DataflowExpression.DataflowExpressionsCollector listener)

Description copied from class: DataflowComplexExpression

Subscribes the listener to all the arguments

Overrides:

subscribe in class DataflowComplexExpression<java.lang.Object>