SinkNode

constructor(label: String, source: PushInputChannel<InputT>)

Parameters

InputT

the type of entities received

label

the name of this node

source

the input channel from which entities are received