PumpNode
class PumpNode<T>(label: String, source: PullInputChannel<T>, destination: PushOutputChannel<T>) : Node
Converts from pull-based to push-based flow. Actively pulls entities from the source and pushes them to the destination when both are ready.
Parameters
T
the type of entities being pumped
label
the name of this node
source
the input channel from which entities are pulled
destination
the output channel where entities are pushed