Merge pull request #27 from clue-labs/decoder-types

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

Author: SimonFrings

src/Decoder.php

@@ -88,6 +88,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

@@ -160,6 +160,14 @@ public function testEmitDataWithBufferSizeOverflowWillForwardOverflowError()
         $this->input->emit('data', array("hello\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 testEmitEndWillForwardEnd()
     {
         $this->decoder->on('data', $this->expectCallableNever());