Package | Description |
---|---|
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 |
Modifier and Type | Field and Description |
---|---|
private java.util.Collection<DataflowChannelListener<T>> |
DataflowChannelEventOrchestrator.listeners |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<DataflowChannelListener<T>> |
DataflowChannelEventListenerManager.getListeners() |
java.util.Collection<DataflowChannelListener<T>> |
DataflowChannelEventOrchestrator.getListeners() |
Modifier and Type | Method and Description |
---|---|
void |
DataflowChannelEventListenerManager.addDataflowChannelListener(DataflowChannelListener<T> listener) |
void |
DataflowChannelEventOrchestrator.addDataflowChannelListener(DataflowChannelListener<T> listener) |
void |
DataflowChannelEventListenerManager.removeDataflowChannelListener(DataflowChannelListener<T> listener) |
void |
DataflowChannelEventOrchestrator.removeDataflowChannelListener(DataflowChannelListener<T> listener) |
Modifier and Type | Method and Description |
---|---|
void |
DataflowChannelEventListenerManager.addAllDataflowChannelListeners(java.util.Collection<DataflowChannelListener<T>> listeners) |
void |
DataflowChannelEventOrchestrator.addAllDataflowChannelListeners(java.util.Collection<DataflowChannelListener<T>> listeners) |
Modifier and Type | Method and Description |
---|---|
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
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
StreamCore.addUpdateListener(DataflowChannelListener<T> updateListener) |
Modifier and Type | Method and Description |
---|---|
private void |
StreamCore.addUpdateListeners(java.util.Collection<DataflowChannelListener<T>> updateListeners) |
Constructor and Description |
---|
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
|