PushForkNode
constructor(label: String, source: PushInputChannel<T>, destinations: List<PushOutputChannel<T>>, policy: ForkPolicy<T> = forkPolicy(RandomPolicy()))
Parameters
T
the type of entities being routed
label
the name of this node
source
the input channel from which entities are received
destinations
the list of output channels to route entities to
policy
the ForkPolicy that determines which destination receives each entity (defaults to random)