PumpNode

constructor(label: String, source: PullInputChannel<T>, destination: PushOutputChannel<T>)

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