StreamProcessor.this

Constructor which accepts a custom throttler. (For standard throttling behaviour, based on the number of busy tasks, use the other ctor.)

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

Parameters

throttler ISuspendableThrottler: custom throttler to use.

Meta

Source

See Implementation

ocean task util StreamProcessor StreamProcessor constructors

this

functions

variables

task_pool