Replaced fgets with fread for binary messages

Author: byrnedo

src/Connection.php

@@ -157,17 +157,13 @@ private function send($payload)
      */
     private function receive($len = null)
     {
+
         if ($len) {
-            $line = fgets($this->streamSocket, $len + 1);
+            $line = fread($this->streamSocket, $len);
         } else {
             $line = fgets($this->streamSocket);
         }
-
-        if ($line === false) {
-            return $line;
-        } else {
-            return trim($line);
-        }
+        return $line;
     }
 
     /**
@@ -337,14 +333,14 @@ private function handleMSG($line)
     {
         $parts = explode(' ', $line);
         $subject = null;
-        $length = $parts[3];
+        $length = trim($parts[3]);
         $sid = $parts[2];
 
         if (count($parts) == 5) {
-            $length = $parts[4];
+            $length = trim($parts[4]);
             $subject = $parts[3];
         } elseif (count($parts) == 4) {
-            $length = $parts[3];
+            $length = trim($parts[3]);
             $subject = $parts[1];
         }
 
@@ -373,7 +369,8 @@ public function wait($quantity = 0)
         $count = 0;
         while (!feof($this->streamSocket)) {
             $line = $this->receive();
-            if ($line === false) {
+
+            if (sizeof($line) === 0) {
                 return null;
             }