class AnySeqCastAny
AnySeqCastAny is used to connect many source processes to many destination process such that an incoming data object read from inputAny will be written to all the processes connected to the outputAny channel. It essentially provides a one place buffer in that as soon as input is ready it can be read and then written to the outputAny channels.
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 UniversalTerminator object to each of the destination processes. The incoming data is not modified in any manner.
Behaviour: while true o = input.read() for ( i in 1..destinations) outputAny.write( o.clone() )
outputAny
- A one2any 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. destinations
- The number of destination processes.Type | Name and description |
---|---|
int |
destinations |
ChannelInput |
inputAny |
ChannelOutput |
outputAny |
int |
sources |
Constructor and description |
---|
AnySeqCastAny
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk