ServiceNode

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

Parameters

T

the type of entities being served

label

the name of this node

source

the input channel from which entities arrive

destination

the output channel where processed entities are sent

delayProvider

the DelayProvider that determines service duration for each entity

numServers

the number of parallel servers