StreamProcessor.task_pool

Pool of tasks used for processing stream data. Size of the pool is configured from StreamProcessor constructor and defines how fast the data can be consumed from streams (together with system-wide worker fiber count configured in scheduler).

class StreamProcessor(TaskT : Task)
protected
ThrottledTaskPool!(TaskT) task_pool;

Meta