class RequestingFanAny
RequestingFanAny writes a signal to the outRequestAny channel; it then reads an object from inResponseAny and then writes the input object to the output channel.
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.
Typically this process will be used to send a request for data to a process on another node in a cluster based system.
Behaviour: while true outRequestAny.write(signal) outputAny.write( inResponseAny.read() )
outRequestAny
- A one2any Channel used to write a signal to a previous OneFanRequestedAny processinResponseAny
- A one2Any Channel used to read an incoming data object from the previous processoutputAny
- A one2Any or possibly one2one 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 |
inResponseAny |
ChannelOutput |
outRequestAny |
ChannelOutput |
outputAny |
Constructor and description |
---|
RequestingFanAny
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk