code: 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;
          }
      }
docs: @throws Exception\RuntimeException
  
  @return Status\WorkerStatus