Lines Matching refs:bytes
88 $bytes = $this->socket->read();
90 if ($bytes === false) {
94 $this->buffer .= $bytes;
102 $this->toConsume .= $buffer->bytes();
155 * @param string $bytes
158 protected function unwrap($bytes) : Buffer
160 return new Buffer($bytes, \strlen($bytes));
164 * Decode the bytes to an object. If you have a partial object, throw the PartialMessageException and the queue
167 * @param string $bytes
171 protected abstract function decode($bytes) : Message;