PullJoinNode
constructor(label: String, sources: List<PullInputChannel<T>>, destination: PullOutputChannel<T>, policy: JoinPolicy<T> = joinPolicy(RandomPolicy()))
Parameters
T
the type of entities being merged
label
the name of this node
sources
the list of input channels to merge from
destination
the output channel where merged entities are sent
policy
the JoinPolicy that determines which source to pull from (defaults to random)