Lines Matching refs:queue
56 protected $queue;
78 public function __construct(array $options, ClientQueue $queue = null, SocketPool $pool = null, ClientProtocolHandlerFactory $clientProtocolHandlerFactory = null)
84 $this->queue = $queue;
155 $this->queue(),
165 $this->queue(),
173 $this->queue()->close();
195 return ($this->queue !== null && $this->queue->isConnected());
201 protected function queue(): ClientQueue
203 if ($this->queue === null) {
204 $this->queue = new ClientQueue($this->pool);
207 return $this->queue;