Package-level declarations
Types
Link copied to clipboard
class PullForkNode<T>(label: String, source: PullInputChannel<T>, destinations: List<PullOutputChannel<T>>) : Node
Distributes entities from a single pull input to multiple pull outputs. Each output independently pulls from the source when needed.
Link copied to clipboard
class PushForkNode<T>(label: String, source: PushInputChannel<T>, destinations: List<PushOutputChannel<T>>, policy: ForkPolicy<T> = forkPolicy(RandomPolicy())) : Node
Routes incoming entities to one of multiple output destinations based on a ForkPolicy. Each entity is sent to a single chosen destination. The input remains open only if at least one output destination is open.