Removed incorrect trim of fread contents

Also fixed trunctated read when read bytes are less than expected.
Changed mtu to 1500 as this seems like the default mtu in most networks.

Author: byrnedo

src/Nats/Connection.php

@@ -20,7 +20,7 @@ class Connection
      * Chunk size in bytes to use when reading with fread.
      * @var int
      */
-    private $chunkSize = 8192;
+    private $chunkSize = 1500;
 
     /**
      * Return the number of pings.
@@ -171,11 +171,9 @@ private function receive($len = null)
                     $chunkSize = $bytesLeft;
                 }
 
-                $line .= fread($this->streamSocket, $chunkSize);
-                $receivedBytes += $chunkSize;
-            }
-            if (strlen($line) > 2) {
-                $line = substr($line, 0, -2);
+                $readChunk = fread($this->streamSocket, $chunkSize);
+                $receivedBytes += strlen($readChunk);
+                $line .= $readChunk;
             }
         } else {
             $line = fgets($this->streamSocket);

test/ConnectionTest.php

@@ -13,7 +13,7 @@ class ConnectionTest extends \PHPUnit_Framework_TestCase
     /**
      * Client.
      *
-     * @var resource Client
+     * @var Nats\Connection Client
      */
     private $c;
 
@@ -97,21 +97,66 @@ public function testReconnect()
      */
     public function testRequest()
     {
-        $this->c->subscribe(
-            "sayhello",
-            function ($res) {
-                $res->reply("Hello, ".$res->getBody(). " !!!");
-            }
-        );
 
-        $this->c->request(
-            'sayhello',
-            'McFly',
-            function ($message) {
-                $this->assertNotNull($message);
-                $this->assertEquals($message, 'Hello, McFly !!!');
-            }
-        );
+        $i = 0;
+        do {
+            $this->c->subscribe(
+                "sayhello$i",
+                function ($res) {
+                    $res->reply("Hello, ".$res->getBody(). " !!!");
+                }
+            );
+
+            $this->c->request(
+                "sayhello$i",
+                'McFly',
+                function ($message) {
+                    $this->assertNotNull($message);
+                    $this->assertEquals($message, 'Hello, McFly !!!');
+                }
+            );
+
+            $i++;
+
+        } while ($i < 100);
+    }
+
+    /**
+     * Test Request command with large payload.
+     *
+     * @return void
+     */
+    public function testLargeRequest()
+    {
+
+        $content = file_get_contents(dirname(__FILE__).'/test.pdf');
+        
+        $contentLen = strlen($content);
+
+        $i = 0;
+        do {
+
+            $this->c->subscribe(
+                "saybighello$i",
+                function ($res) use ($contentLen) {
+                    $gotLen = strlen($res->getBody());
+                    $this->assertEquals($contentLen, $gotLen);
+                    $res->reply($gotLen);
+                }
+            );
+
+            $this->c->request(
+                "saybighello$i",
+                $content,
+                function ($message) use ($contentLen) {
+                    $this->assertNotNull($message);
+                    $this->assertEquals($message->getBody(), $contentLen);
+                }
+            );
+
+            $i++;
+        } while ($i < 100);
+
     }
 
     /**