PullForkNode

constructor(label: String, source: PullInputChannel<T>, destinations: List<PullOutputChannel<T>>)

Parameters

T

the type of entities being distributed

label

the name of this node

source

the input channel from which entities are pulled

destinations

the list of output channels to distribute entities to