groovyx.gpars.dataflow
Interface DataflowChannel<T>

All Superinterfaces:

DataflowReadChannel<T>, DataflowWriteChannel<T>, SelectableChannel<T>

All Known Implementing Classes:

DataflowQueue, DataflowVariable, DataflowVariable.RemoteDataflowVariable, LazyDataflowVariable, SyncDataflowQueue, SyncDataflowVariable

public interface DataflowChannel<T>
extends DataflowReadChannel<T>, DataflowWriteChannel<T>

A common interface for all dataflow variables, streams or queues

Author:

Vaclav Pech Date: 21st Sep 2010

Method Summary

Methods inherited from interface groovyx.gpars.dataflow.DataflowReadChannel

binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, filter, filter, filter, filter, filter, filter, getEventManager, getVal, getVal, getValAsync, getValAsync, chainWith, chainWith, chainWith, chainWith, chainWith, chainWith, choice, choice, choice, choice, choice, choice, into, into, into, into, into, into, isBound, length, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, or, or, rightShift, separate, separate, separate, separate, separate, separate, split, split, split, split, split, split, split, split, split, split, split, split, tap, tap, tap, tap, tap, tap, then, then, then, whenBound, whenBound, whenBound, whenBound

Methods inherited from interface groovyx.gpars.dataflow.SelectableChannel

poll, wheneverBound, wheneverBound

Methods inherited from interface groovyx.gpars.dataflow.DataflowWriteChannel

bind, leftShift, leftShift