public function onPipeMessage(Server $server, int $srcWorkerId, string $message)
    {
        /* @var PipeMessageInterface $pipeMessage */
        $pipeMessage = App::getBean(PipeMessage::class);
        list($type, $data) = $pipeMessage->unpack($message);

        App::trigger(AppEvent::PIPE_MESSAGE, null, $type, $data, $srcWorkerId);
    }
public function onPipeMessage(Server $server, int $srcWorkerId, string $message)
    {
        /* @var PipeMessageInterface $pipeMessage */
        $pipeMessage = App::getBean(PipeMessage::class);
        list($type, $data) = $pipeMessage->unpack($message);

        App::trigger(AppEvent::PIPE_MESSAGE, null, $type, $data, $srcWorkerId);
    }
public function onPipeMessage ( Server $ server , int $ srcWorkerId , string $ message ) { /* @var PipeMessageInterface $pipeMessage */ $ pipeMessage = App :: getBean ( PipeMessage :: class ) ; list ( $ type , $ data ) = $ pipeMessage -> unpack ( $ message ) ; App :: trigger ( AppEvent :: PIPE_MESSAGE , null , $ type , $ data , $ srcWorkerId ) ; }
onPipeMessage event callback

@param \Swoole\Server $server
@param int            $srcWorkerId
@param string         $message
@return void
@throws \InvalidArgumentException
onPipeMessage event callback