private function receive()

in src/Apache/Ignite/Internal/Connection/ClientSocket.php [162:173]

• 12 lines of code
• 4 McCabe index (conditional complexity)

    private function receive(MessageBuffer $buffer, int $minSize): void
    {
        while ($buffer->getLength() < $minSize)
        {
            $chunk = fread($this->socket, $this->receiveChunkSize);
            if ($chunk === false || $chunk === '') {
                throw new OperationStatusUnknownException('Error while reading data from the server');
            } else {
                $buffer->append($chunk);
            }
        }
    }