org.trianacode.taskgraph.service

Class RunnableCable

java.lang.Object

org.trianacode.taskgraph.imp.CableImp

org.trianacode.taskgraph.service.QueueCable

org.trianacode.taskgraph.service.DataCable

org.trianacode.taskgraph.service.RunnableCable

All Implemented Interfaces:

java.io.Serializable, Cable, NodeListener, InputCable, IOCable, OutputCable

public class RunnableCable
extends DataCable

A local cable with type checking.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.trianacode.taskgraph.service.DataCable

DATA_CABLE

Fields inherited from class org.trianacode.taskgraph.imp.CableImp

NON_RUNNABLE_CABLE

Fields inherited from interface org.trianacode.taskgraph.Cable

CONTROL_CABLE_TYPE

Constructor Summary

Constructors

Constructor and Description
RunnableCable()

Method Summary

Methods

Modifier and Type	Method and Description
void	connect(Node sendnode, Node recnode) A local cable must be created by giving a reference to a RunnableInstance object so that when we use non-blocking sending of data we can notify the RunnableInstance object when each packet has finished

Methods inherited from class org.trianacode.taskgraph.service.DataCable

getType

Methods inherited from class org.trianacode.taskgraph.service.QueueCable

disconnect, finalize, flush, isDataReady, isDataSent, nodeChildChanged, nodeConnected, nodeDisconnected, nodeParentChanged, parameterNameSet, preReceive, preSend, reconnect, recv, resume, send, sendNonBlocking, suspend

Methods inherited from class org.trianacode.taskgraph.imp.CableImp

addCableListener, connects, contains, getReceivingNode, getReceivingTask, getSendingNode, getSendingTask, isConnected, removeCableListener, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.trianacode.taskgraph.Cable

addCableListener, connects, contains, getReceivingNode, getReceivingTask, getSendingNode, getSendingTask, isConnected, removeCableListener

Constructor Detail

RunnableCable

public RunnableCable()

Method Detail

connect

public void connect(Node sendnode,
           Node recnode)
             throws CableException

A local cable must be created by giving a reference to a RunnableInstance object so that when we use non-blocking sending of data we can notify the RunnableInstance object when each packet has finished

Specified by:

connect in interface Cable

Overrides:

connect in class QueueCable

Throws:

CableException