T
- The type of messages to pass through the streampublic class DataflowStreamWriteAdapter<T> extends WithSerialId implements DataflowWriteChannel<T>
Modifier and Type | Class and Description |
---|---|
private class |
DataflowStreamWriteAdapter.BindDataflowStream<T> |
Modifier and Type | Field and Description |
---|---|
private StreamCore<T> |
head |
serialHandle
Constructor and Description |
---|
DataflowStreamWriteAdapter(StreamCore<T> stream)
Creates a new adapter
|
Modifier and Type | Method and Description |
---|---|
void |
bind(T value)
Assigns a value to the variable.
|
protected StreamCore<T> |
getHead() |
DataflowWriteChannel<T> |
leftShift(DataflowReadChannel<T> ref)
Assigns a value from one DataflowVariable instance to this variable.
|
DataflowWriteChannel<T> |
leftShift(T value)
Assigns a value to the variable.
|
private void |
notifyRemote(T value) |
java.lang.String |
toString() |
private StreamCore<T> |
updateHead()
Moves head
|
createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace
private StreamCore<T> head
public DataflowStreamWriteAdapter(StreamCore<T> stream)
stream
- The stream to wrappublic final DataflowWriteChannel<T> leftShift(T value)
DataflowWriteChannel
leftShift
in interface DataflowWriteChannel<T>
value
- The value to assignpublic final DataflowWriteChannel<T> leftShift(DataflowReadChannel<T> ref)
DataflowWriteChannel
leftShift
in interface DataflowWriteChannel<T>
ref
- The DataflowVariable instance the value of which to bindpublic final void bind(T value)
DataflowWriteChannel
bind
in interface DataflowWriteChannel<T>
value
- The value to assignprivate StreamCore<T> updateHead()
public java.lang.String toString()
toString
in class java.lang.Object
protected final StreamCore<T> getHead()
private void notifyRemote(T value)