org.trianacode.taskgraph.service

Interface OutputCable

All Superinterfaces:

Cable

All Known Subinterfaces:

IOCable

All Known Implementing Classes:

DataCable, LocalCable, QueueCable, RunnableCable

public interface OutputCable
extends Cable

Field Summary

Fields inherited from interface org.trianacode.taskgraph.Cable

CONTROL_CABLE_TYPE

Method Summary

Methods

Modifier and Type	Method and Description
void	flush() Flushes data in the pipe
boolean	isDataSent()
void	resume() Unsuspends a pipe
void	send(java.lang.Object data) Blocking call to send the data from the sending task to the receiving task.
void	sendNonBlocking(java.lang.Object data) Non-blocking call to send the data from the sending task to the receiving task.
void	suspend() Suspends the pipe.

Methods inherited from interface org.trianacode.taskgraph.Cable

addCableListener, connect, connects, contains, disconnect, getReceivingNode, getReceivingTask, getSendingNode, getSendingTask, getType, isConnected, reconnect, removeCableListener

Method Detail

send

void send(java.lang.Object data)

Blocking call to send the data from the sending task to the receiving task.

Parameters:

data - the data to be sent

sendNonBlocking

void sendNonBlocking(java.lang.Object data)

Non-blocking call to send the data from the sending task to the receiving task.

Parameters:

data - the data to be sent

isDataSent

boolean isDataSent()

Returns:

true if the data sent

suspend

void suspend()

Suspends the pipe. Any new data sent to the pipe should be ignored

flush

void flush()

Flushes data in the pipe

resume

void resume()

Unsuspends a pipe