Overview  Package   Class  Deprecated  Index  Help 
org.codehaus.gpars
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

groovyx.gpars.dataflow.stream
[Java] Class DataflowStreamWriteAdapter

java.lang.Object
  groovyx.gpars.dataflow.stream.DataflowStreamWriteAdapter
All Implemented Interfaces:
DataflowWriteChannel
@java.lang.SuppressWarningspublic final DataflowWriteChannel leftShift(final T value) {
public class DataflowStreamWriteAdapter

Adapts a DataflowStream to accommodate for the DataflowWriteChannel interface. It also synchronizes all changes to the underlying stream allowing multiple threads accessing the stream concurrently.

Parameters:
- The type of messages to pass through the stream
Authors:
Vaclav Pech

Field Summary
private StreamCore head

 
Constructor Summary
DataflowStreamWriteAdapter(StreamCore stream)

 
Method Summary
void bind(java.lang.Object value)

protected StreamCore getHead()

DataflowWriteChannel leftShift(java.lang.Object value)

DataflowWriteChannel leftShift(DataflowReadChannel ref)

java.lang.String toString()

private StreamCore updateHead()

 
Methods inherited from class java.lang.Object
java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()
 

Field Detail

head

private StreamCore head

 
Constructor Detail

DataflowStreamWriteAdapter

public DataflowStreamWriteAdapter(StreamCore stream)

 
Method Detail

bind

@java.lang.Override
public final void bind(java.lang.Object value)

getHead

protected final StreamCore getHead()

leftShift

@java.lang.Override}
public final DataflowWriteChannel leftShift(java.lang.Object value)

leftShift

@java.lang.Override*/
public final DataflowWriteChannel leftShift(DataflowReadChannel ref)

toString

@java.lang.Override
public java.lang.String toString()

updateHead

private StreamCore updateHead()

 

Copyright © 2008–2013 Václav Pech. All Rights Reserved.