Uses of Interface
groovyx.gpars.dataflow.DataflowChannelListener

Packages that use DataflowChannelListener

groovyx.gpars.dataflow.impl
groovyx.gpars.dataflow.operator	This package holds classes representing operators and channels necessary for full dataflow concurrency.
groovyx.gpars.dataflow.stream

Uses of DataflowChannelListener in groovyx.gpars.dataflow.impl

Fields in groovyx.gpars.dataflow.impl with type parameters of type DataflowChannelListener

private java.util.Collection<DataflowChannelListener<T>>

DataflowChannelEventOrchestrator.listeners

Methods in groovyx.gpars.dataflow.impl that return types with arguments of type DataflowChannelListener

java.util.Collection<DataflowChannelListener<T>>	DataflowChannelEventListenerManager.getListeners()
java.util.Collection<DataflowChannelListener<T>>	DataflowChannelEventOrchestrator.getListeners()

Methods in groovyx.gpars.dataflow.impl with parameters of type DataflowChannelListener

void	DataflowChannelEventListenerManager.addDataflowChannelListener(DataflowChannelListener<T> listener)
void	DataflowChannelEventOrchestrator.addDataflowChannelListener(DataflowChannelListener<T> listener)
void	DataflowChannelEventListenerManager.removeDataflowChannelListener(DataflowChannelListener<T> listener)
void	DataflowChannelEventOrchestrator.removeDataflowChannelListener(DataflowChannelListener<T> listener)

Method parameters in groovyx.gpars.dataflow.impl with type arguments of type DataflowChannelListener

void	DataflowChannelEventListenerManager.addAllDataflowChannelListeners(java.util.Collection<DataflowChannelListener<T>> listeners)
void	DataflowChannelEventOrchestrator.addAllDataflowChannelListeners(java.util.Collection<DataflowChannelListener<T>> listeners)

Uses of DataflowChannelListener in groovyx.gpars.dataflow.operator

Methods in groovyx.gpars.dataflow.operator with parameters of type DataflowChannelListener

void	DataflowProcessor.registerChannelListenersToAllInputs(DataflowChannelListener<java.lang.Object> handler) Registers the provided handler to all input channels
(package private) void	DataflowProcessorActor.registerChannelListenersToAllInputs(DataflowChannelListener<java.lang.Object> handler) Registers the provided handler to all input channels

Uses of DataflowChannelListener in groovyx.gpars.dataflow.stream

Methods in groovyx.gpars.dataflow.stream with parameters of type DataflowChannelListener

(package private) void

StreamCore.addUpdateListener(DataflowChannelListener<T> updateListener)

Method parameters in groovyx.gpars.dataflow.stream with type arguments of type DataflowChannelListener

private void

StreamCore.addUpdateListeners(java.util.Collection<DataflowChannelListener<T>> updateListeners)

Constructor parameters in groovyx.gpars.dataflow.stream with type arguments of type DataflowChannelListener

DataflowStream(java.util.Collection<MessageStream> wheneverBoundListeners, java.util.Collection<DataflowChannelListener<T>> updateListeners)

StreamCore(DataflowVariable<T> first, java.util.Collection<MessageStream> wheneverBoundListeners, java.util.Collection<DataflowChannelListener<T>> updateListeners)

SyncDataflowStream(int parties, java.util.Collection<MessageStream> wheneverBoundListeners, java.util.Collection<DataflowChannelListener<T>> updateListeners)
Creates an empty stream with the specified listeners set