public function onWorkersStart(WorkerPoolInterface $pool)
    {
        $workers = $pool->getWorkers();
        $count = count($workers);
        $this->eventEmitter->emit('peridot.concurrency.stream-select.start', [$count]);
    }