catch Guzzle parser exception

Author: danil zakablukovskii

src/Request.php

@@ -132,7 +132,13 @@ public function handleData($data)
         $this->buffer .= $data;
 
         if (false !== strpos($this->buffer, "\r\n\r\n")) {
-            list($response, $bodyChunk) = $this->parseResponse($this->buffer);
+            try {
+                list($response, $bodyChunk) = $this->parseResponse($this->buffer);
+            } catch (\InvalidArgumentException $exception) {
+                $this->emit('error', [$exception, $this]);
+
+                return;
+            }
 
             $this->buffer = null;
 

tests/RequestTest.php

@@ -220,6 +220,28 @@ public function requestShouldEmitErrorIfConnectionEmitsError()
         $request->handleError(new \Exception('test'));
     }
 
+    /** @test */
+    public function requestShouldEmitErrorIfGuzzleParseThrowsException()
+    {
+        $requestData = new RequestData('GET', 'http://www.example.com');
+        $request = new Request($this->connector, $requestData);
+
+        $this->successfulConnectionMock();
+
+        $handler = $this->createCallableMock();
+        $handler->expects($this->once())
+            ->method('__invoke')
+            ->with(
+                $this->isInstanceOf('\InvalidArgumentException'),
+                $this->isInstanceOf('React\HttpClient\Request')
+            );
+
+        $request->on('error', $handler);
+
+        $request->writeHead();
+        $request->handleData("\r\n\r\n");
+    }
+
     /**
      * @test
      * @expectedException Exception