groovyx.gpars.dataflow
Class DataflowExpression.BindDataflow<T>

java.lang.Object
  groovyx.gpars.serial.SerialMsg
      groovyx.gpars.dataflow.DataflowExpression.BindDataflow<T>

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

DataflowExpression<T>

public static class DataflowExpression.BindDataflow<T>
extends SerialMsg

Represents a remote message binding a value to a remoted DataflowExpression

See Also:

Serialized Form

Field Summary

private DataflowExpression<T>	expr
private T	message
private static long	serialVersionUID

Fields inherited from class groovyx.gpars.serial.SerialMsg

hostId

Constructor Summary

DataflowExpression.BindDataflow(DataflowExpression<T> expr, T message, java.util.UUID hostId)

Method Summary

void	execute(RemoteConnection conn) Performs the actual bind on the remote host

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

expr

private final DataflowExpression<T> expr

message

private final T message

Constructor Detail

DataflowExpression.BindDataflow

public DataflowExpression.BindDataflow(DataflowExpression<T> expr,
                                       T message,
                                       java.util.UUID hostId)

Parameters:

expr - The local DataflowExpression instance

message - The actual value to bind

hostId - The identification of the host to send the bind information to

Method Detail

execute

public void execute(RemoteConnection conn)

Performs the actual bind on the remote host

Overrides:

execute in class SerialMsg

Parameters:

conn - The connection object