Package-level declarations
Types
Link copied to clipboard
class PullJoinNode<T>(label: String, sources: List<PullInputChannel<T>>, destination: PullOutputChannel<T>, policy: JoinPolicy<T> = joinPolicy(RandomPolicy())) : Node
Merges entities from multiple pull inputs into a single pull output based on a JoinPolicy. When the destination pulls, it selects one of the ready sources and pulls from it.
Link copied to clipboard
class PushJoinNode<T>(label: String, sources: List<PushInputChannel<T>>, destination: PushOutputChannel<T>) : Node
Merges entities from multiple push inputs into a single push output. Any entity arriving from any source is immediately forwarded to the destination.