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

@param WorkerPoolInterface $pool
@return void
Listen for start of workers .