Configuration.throttleConcurrency()
Description
Appends a throttleConcurrency filter to the current pipeline layout.
A throttleConcurrency filter limits the number of concurrent streams.
- INPUT - Any types of Events.
- OUTPUT - Same Events as the input.
This filter passes down everything unaltered. It doesn't change anything in the event stream. It only delays them.
Syntax
pipy().pipeline().throttleConcurrency(new algo.Quota(quota))pipy().pipeline().throttleConcurrency(() => getQuota())
Parameters
throttleConcurrency(quota)
quota
A Quota object or a function returns it.
Return Value
The same Configuration object.