src/Performer.php
public function pushActionResultInfo(ActionResultingPushDto $resultingPushDto)
    {
        $this->subscriberSocket->setSockOpt(\ZMQ::SOCKOPT_UNSUBSCRIBE, "");

        $this->performerEarlyTerminated->setStandOnSubscription(false);

        $this->logger->debug("Performer was unsubscribed.");

        $this->initOrCheckPushConnection();

        $this->pushSocket->send(serialize($resultingPushDto));

        $this->logger->debug("Performer send actionResulting msg.");

        return null;
    }
public function pushActionResultInfo(ActionResultingPushDto $resultingPushDto)
    {
        $this->subscriberSocket->setSockOpt(\ZMQ::SOCKOPT_UNSUBSCRIBE, "");

        $this->performerEarlyTerminated->setStandOnSubscription(false);

        $this->logger->debug("Performer was unsubscribed.");

        $this->initOrCheckPushConnection();

        $this->pushSocket->send(serialize($resultingPushDto));

        $this->logger->debug("Performer send actionResulting msg.");

        return null;
    }
After action done worker-subscriber stop subscription and by push socket send action's info
@param ActionResultingPushDto $resultingPushDto
@return null