fix(read stream) consume buffer multiple times

Connection/Connection.php

@@ -658,12 +658,14 @@ public function getRemoteAddress()
      * Warning: if this method returns false, it means that the buffer is empty.
      * You should use the Hoa\Stream::setStreamBlocking(true) method.
      *
-     * @param   int    $length    Length.
-     * @param   int    $flags     Flags.
+     * @param   int     $length    Length.
+     * @param   int     $flags     Flags.
+     * @param   boolean $keepReading If we loop over stream to seek length data ot not.
+     * @param   int     $chunk     Length bloc read in the stream.
      * @return  string
      * @throws  \Hoa\Socket\Exception
      */
-    public function read($length, $flags = 0)
+    public function read($length, $flags = 0, $keepReading = true, $chunk = null)
     {
         if (null === $this->getStream()) {
             throw new Socket\Exception(
@@ -681,21 +683,31 @@ public function read($length, $flags = 0)
             );
         }
 
-        if (true === $this->isEncrypted()) {
-            return fread($this->getStream(), $length);
+        if (is_int($chunk)) {
+            stream_set_chunk_size($this->getStream(), $chunk);
         }
 
-        if (false === $this->isRemoteAddressConsidered()) {
-            return stream_socket_recvfrom($this->getStream(), $length, $flags);
-        }
+        $out = '';
 
-        $out = stream_socket_recvfrom(
-            $this->getStream(),
-            $length,
-            $flags,
-            $address
-        );
-        $this->_remoteAddress = !empty($address) ? $address : null;
+        do {
+            $readLength = $length - strlen($out);
+
+            if (0 >= $readLength) {
+                break;
+            }
+
+            if (true === $this->isEncrypted()) {
+                $buffer = fread($this->getStream(), $readLength);
+            } else {
+                $buffer = stream_socket_recvfrom($this->getStream(), $readLength, $flags);
+            }
+
+            if ('' !== $buffer && is_string($buffer)) {
+                $out .= $buffer;
+            } else {
+                break;
+            }
+        } while($keepReading);
 
         return $out;
     }