StreamProcessor.this

Constructor

NB: configure suspend point so that there is always at least one "extra" spare task in the pool available after the limit is reached. This is necessary because throttling happens in the end of the task, not after it finishes and gets recycled.

  1. this(ISuspendableThrottler throttler)
  2. this(ThrottlerConfig throttler_config)
    class StreamProcessor(TaskT : Task)

Parameters

throttler_config ThrottlerConfig

The throttler configuration

Meta