src/Producer.php
protected function cleanManagerSet()
    {
        foreach ($this->managerSet as $managerKey => $manager) {

            /** @var $manager \Thread */
            if (!$manager->isRunning()) {
                $this->getLogger()->debug("Daemon clean old manager : {$managerKey}", [__NAMESPACE__]);
                unset($this->managerSet[$managerKey]);
            }
        }

        return $this;
    }
protected function cleanManagerSet()
    {
        foreach ($this->managerSet as $managerKey => $manager) {

            /** @var $manager \Thread */
            if (!$manager->isRunning()) {
                $this->getLogger()->debug("Daemon clean old manager : {$managerKey}", [__NAMESPACE__]);
                unset($this->managerSet[$managerKey]);
            }
        }

        return $this;
    }
protected function cleanManagerSet ( ) { foreach ( $ this -> managerSet as $ managerKey => $ manager ) { /** @var $manager \Thread */ if ( ! $ manager -> isRunning ( ) ) { $ this -> getLogger ( ) -> debug ( "Daemon clean old manager : {$managerKey}" , [ __NAMESPACE__ ] ) ; unset ( $ this -> managerSet [ $ managerKey ] ) ; } } return $ this ; }
Clean Manager SET

Checking each manager in ManagerSet and delete manager that done theirs work

@return $this
Clean Manager SET