class AnyFanOne
AnyFanOne is used to connect many source processes to one destination process such that any incoming data object will be written to the next process using the output channel.
Once the UniversalTerminator is read from the any end of the input channel, a tally will be kept until all the UniversalTerminator objects are read from all the source processes. The process will then output a single UniversalTerminator object. The incoming data is not modified in any manner.
Behaviour: while true output.write( inputAny.read() )
output
- A one2one Channel used to write data objects to the next processinputAny
- An any2one channel from which incoming data objects are readsources
- The number of source processes connected to the Any channel end. Type | Name and description |
---|---|
ChannelInput |
inputAny |
ChannelOutput |
output |
int |
sources |
Constructor and description |
---|
AnyFanOne
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk