class OneFanAny
OneFanAny is used to connect a source process to any number of destination processes such that an object read from input will be written to the next process that is waiting on outputAny.
Once the UniversalTerminator is read it will be copied to all of the Any channel ends. The incoming data is not modified in any manner.
Behaviour: while true outputAny.write( input.read() )
input
- A one2one Channel used to read data objects from the previous processoutputAny
- A one2Any channel to which the incoming data object is writtendestinations
- The number of receiving processes connected to the Any channel end.Type | Name and description |
---|---|
int |
destinations |
ChannelInput |
input |
ChannelOutput |
outputAny |
Constructor and description |
---|
OneFanAny
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk