DataflowStreamWriteAdapter (org.codehaus.gpars)

| Detail:
Field
Constructor
Method

groovyx.gpars.dataflow.stream.DataflowStreamWriteAdapter

All Implemented Interfaces and Traits:

DataflowWriteChannel
```
@java.lang.SuppressWarnings({"SynchronizedMethod"})
public class DataflowStreamWriteAdapter
extends WithSerialId
```
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

Nested Class Summary

Nested classes
Modifiers	Name	Description
`private class`	`DataflowStreamWriteAdapter.BindDataflowStream`

Field Summary

Fields
Modifiers	Name	Description
`private StreamCore<T>`	`head`

Inherited fields
Fields inherited from class	Fields
`class WithSerialId`	`serialHandle, serialVersionUID`

Constructor Summary

Constructors
Constructor and description
`DataflowStreamWriteAdapter (StreamCore<T> stream)` Creates a new adapter

Methods Summary

Methods
Type	Name and description
`void`	`bind(T value)`
`protected StreamCore<T>`	`getHead()`
`DataflowWriteChannel<T>`	`leftShift(T value)`
`DataflowWriteChannel<T>`	`leftShift(DataflowReadChannel<T> ref)`
`private void`	`notifyRemote(T value)`
`java.lang.String`	`toString()`
`private StreamCore<T>`	`updateHead()` Moves head

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class WithSerialId`	`createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace`
`class java.lang.Object`	`java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#wait(long), 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
  - private StreamCore<T> head
- Constructor Detail
  - public DataflowStreamWriteAdapter(StreamCore<T> stream)
    
    Creates a new adapter
    Parameters:
    stream - The stream to wrap
- Method Detail
  - @java.lang.Override public final void bind(T value)
  - protected final StreamCore<T> getHead()
  - @java.lang.Override public final DataflowWriteChannel<T> leftShift(T value)
  - @java.lang.Override public final DataflowWriteChannel<T> leftShift(DataflowReadChannel<T> ref)
  - private void notifyRemote(T value)
  - @java.lang.Override public java.lang.String toString()
  - private StreamCore<T> updateHead()
    
    Moves head
    Returns:
    The old head

| Detail:
Field
Constructor
Method

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