class EmitWithLocal
The EmitWithLocal process is used to send newly instanced data objects of type emitClassName to the rest of the parallel structure. It sends output data objects to one output channel. Once the all the data objects have been created the process terminates and writes a UniversalTerminator object to the output channel. The process makes use of a local class that provides an additional capability for the emit process
Methods required by class emitClassName: initClass( initialData ) createInstance( createData ) Methods required by the local worker class: Behaviour: emitClass.newInstance() emitClass.initClass(initialData) while emitClass.createInstance([localClass, createData]) == normalContinuation output.write(emitClass) emitClass.newInstance()
output
- The one2one channel to which data objects are writteneDetails
- A DataDetails object that specifies the data class to be emitted that
specifies a local classType | Name and description |
---|---|
DataDetails |
eDetails |
String |
logPhaseName |
String |
logPropertyName |
ChannelOutput |
output |
Constructor and description |
---|
EmitWithLocal
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk