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;
        }
    }
@throws Exception\RuntimeException

@return Status\WorkerStatus