BoundedQueueNode
constructor(label: String, source: PushInputChannel<T>, destination: PullOutputChannel<T>, capacity: Int, policy: QueuePolicy<T> = FIFOQueuePolicy())
Parameters
T
the type of entities in the queue
label
the name of this node
source
the input channel from which entities are received
destination
the output channel where entities are sent
capacity
the maximum number of entities the queue can hold
policy
the QueuePolicy that determines entity ordering (defaults to FIFO)