PushJoinNode

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.

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

Constructors

Link copied to clipboard
constructor(label: String, sources: List<PushInputChannel<T>>, destination: PushOutputChannel<T>)

Properties

Link copied to clipboard
override val incoming: List<InputChannel<*, *>>
Link copied to clipboard
Link copied to clipboard
override val outgoing: List<OutputChannel<*, *>>
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
context(_: Simulator)
open fun onStart()
Link copied to clipboard
Link copied to clipboard
open override fun toString(): String