Merge pull request #29 from SimonFrings/decoder-types

Check type of incoming `data` before trying to decode NDJSON

Author: clue

src/Decoder.php

@@ -99,6 +99,11 @@ public function pipe(WritableStreamInterface $dest, array $options = array())
     /** @internal */
     public function handleData($data)
     {
+        if (!\is_string($data)) {
+            $this->handleError(new \UnexpectedValueException('Expected stream to emit string, but got ' . \gettype($data)));
+            return;
+        }
+
         $this->buffer .= $data;
 
         // keep parsing while a newline has been found

tests/DecoderTest.php

@@ -67,6 +67,14 @@ public function testEmitDataBigIntOptionWillForwardAsString()
         $this->input->emit('data', array("999888777666555444333222111000\n"));
     }
 
+    public function testEmitDataWithInvalidTypeWillForwardErrorWithUnexpectedValueException()
+    {
+        $this->decoder->on('data', $this->expectCallableNever());
+        $this->decoder->on('error', $this->expectCallableOnceWith($this->isInstanceOf('UnexpectedValueException')));
+
+        $this->input->emit('data', array(false));
+    }
+
     public function testEmitDataErrorWillForwardError()
     {
         $this->decoder->on('data', $this->expectCallableNever());