SharedWorker.php
public function query()
    {
        AdminEncoding::sendQueryMessage($this->channel, $this->adminCookie);
        foreach ($this->unreceivedMessages as $i => $message) {
            $status = AdminEncoding::getStatusMessage($message);
            if ($status !== null) {
                array_splice($this->unreceivedMessages, $i, 1);

                return $status;
            }
        }
        for (;;) {
            $message = $this->channel->receiveMessage();
            $status = AdminEncoding::getStatusMessage($message);
            if ($status !== null) {
                return $status;
            }
            $this->unreceivedMessages[] = $message;
        }
    }
public function query()
    {
        AdminEncoding::sendQueryMessage($this->channel, $this->adminCookie);
        foreach ($this->unreceivedMessages as $i => $message) {
            $status = AdminEncoding::getStatusMessage($message);
            if ($status !== null) {
                array_splice($this->unreceivedMessages, $i, 1);

                return $status;
            }
        }
        for (;;) {
            $message = $this->channel->receiveMessage();
            $status = AdminEncoding::getStatusMessage($message);
            if ($status !== null) {
                return $status;
            }
            $this->unreceivedMessages[] = $message;
        }
    }
public function query ( ) { AdminEncoding :: sendQueryMessage ( $ this -> channel , $ this -> adminCookie ) ; foreach ( $ this -> unreceivedMessages as $ i => $ message ) { $ status = AdminEncoding :: getStatusMessage ( $ message ) ; if ( $ status !== null ) { array_splice ( $ this -> unreceivedMessages , $ i , 1 ) ; return $ status ; } } for ( ; ; ) { $ message = $ this -> channel -> receiveMessage ( ) ; $ status = AdminEncoding :: getStatusMessage ( $ message ) ; if ( $ status !== null ) { return $ status ; } $ this -> unreceivedMessages [ ] = $ message ; } }
@throws Exception\RuntimeException

@return Status\WorkerStatus
@throws Exception \ RuntimeException