PushJoinNode

constructor(label: String, sources: List<PushInputChannel<T>>, destination: PushOutputChannel<T>)

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