DelayNode

constructor(label: String, source: PushInputChannel<T>, destination: PushOutputChannel<T>, delayProvider: DelayProvider)

Parameters

T

the type of entities passing through

label

the name of this node

source

the input channel from which entities are received

destination

the output channel where delayed entities are sent

delayProvider

the DelayProvider that determines delay duration for each entity