class OneFanRequestedAny
OneFanRequestedAny reads a value from the input channel; it then reads a signal from the inRequestAny and then writes the input object to the outResponseAny 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 respond to a request for data by a process on another node in a cluster based system.
Behaviour: o = input.read() while true inRequestAny.read() outResponseAny.write(o) o = input.read()
input
- A one2one Channel used to read data objects from the previous processinRequestAny
- A one2Any Channel used to read a signal from the requesting processoutResponseAny
- A one2Any or one2one channel to which the incoming data object is written to the requesting processdestinations
- The number of receiving processes connected to the Any channel end.Type | Name and description |
---|---|
int |
destinations |
ChannelInput |
inRequestAny |
ChannelInput |
input |
ChannelOutput |
outResponseAny |
Constructor and description |
---|
OneFanRequestedAny
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk