Merge pull request #61 from ajgarlag/fix-encoding-stream-size

Fix encoding stream size

Author: sagikazarmark

CHANGELOG.md

@@ -3,6 +3,10 @@
 
 ## Unreleased
 
+## Fixed
+
+ - FilteredStream::getSize returns null because the contents size is unknown.
+
 ### Deprecated
 
  - FilteredStream::getReadFilter The read filter is internal and should never be used by consuming code.

spec/Encoding/ChunkStreamSpec.php

@@ -39,4 +39,12 @@ function it_chunks_in_multiple()
 
         $this->getContents()->shouldReturn("6\r\nThis i\r\n6\r\ns a st\r\n4\r\nream\r\n0\r\n\r\n");
     }
+
+    function it_does_not_know_the_content_size()
+    {
+        $stream = new MemoryStream('This is a stream');
+        $this->beConstructedWith($stream, 6);
+
+        $this->getSize()->shouldReturn(null);
+    }
 }

spec/Encoding/CompressStreamSpec.php

@@ -41,4 +41,13 @@ function it_gets_content()
         $stream->rewind();
         $this->getContents()->shouldReturn(gzcompress('This is a test stream'));
     }
+
+    function it_does_not_know_the_content_size()
+    {
+        $stream = new MemoryStream('This is a test stream');
+        $this->beConstructedWith($stream);
+
+        $stream->rewind();
+        $this->getSize()->shouldReturn(null);
+    }
 }

spec/Encoding/DechunkStreamSpec.php

@@ -40,4 +40,12 @@ function it_gets_content()
 
         $this->getContents()->shouldReturn('test');
     }
+
+        function it_does_not_know_the_content_size()
+    {
+        $stream = new MemoryStream("4\r\ntest\r\n4\r\ntest\r\n0\r\n\r\n\0");
+        $this->beConstructedWith($stream);
+
+        $this->getSize()->shouldReturn(null);
+    }
 }

spec/Encoding/DecompressStreamSpec.php

@@ -41,4 +41,12 @@ function it_gets_content()
 
         $this->getContents()->shouldReturn('This is a test stream');
     }
+
+    function it_does_not_know_the_content_size()
+    {
+        $stream = new MemoryStream(gzcompress('This is a test stream'));
+        $this->beConstructedWith($stream);
+
+        $this->getSize()->shouldReturn(null);
+    }
 }

spec/Encoding/DeflateStreamSpec.php

@@ -36,4 +36,12 @@ function it_gets_content()
         $stream->rewind();
         $this->getContents()->shouldReturn(gzdeflate('This is a test stream'));
     }
+
+    function it_does_not_know_the_content_size()
+    {
+        $stream = new MemoryStream('This stream is a test stream');
+        $this->beConstructedWith($stream);
+
+        $this->getSize()->shouldReturn(null);
+    }
 }

spec/Encoding/GzipDecodeStreamSpec.php

@@ -41,4 +41,12 @@ function it_gets_content()
 
         $this->getContents()->shouldReturn('This is a test stream');
     }
+
+    function it_does_not_know_the_content_size()
+    {
+        $stream = new MemoryStream(gzencode('This is a test stream'));
+        $this->beConstructedWith($stream);
+
+        $this->getSize()->shouldReturn(null);
+    }
 }

spec/Encoding/GzipEncodeStreamSpec.php

@@ -41,4 +41,13 @@ function it_gets_content()
         $stream->rewind();
         $this->getContents()->shouldReturn(gzencode('This is a test stream'));
     }
+
+    function it_does_not_know_the_content_size()
+    {
+        $stream = new MemoryStream('This is a test stream');
+        $this->beConstructedWith($stream);
+
+        $stream->rewind();
+        $this->getSize()->shouldReturn(null);
+    }
 }

spec/Encoding/InflateStreamSpec.php

@@ -36,4 +36,12 @@ function it_gets_content()
 
         $this->getContents()->shouldReturn('This is a test stream');
     }
+
+    function it_does_not_know_the_content_size()
+    {
+        $stream = new MemoryStream(gzdeflate('This stream is a test stream'));
+        $this->beConstructedWith($stream);
+
+        $this->getSize()->shouldReturn(null);
+    }
 }

src/Encoding/FilteredStream.php

@@ -138,6 +138,14 @@ public function getContents()
         return $buffer;
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function getSize()
+    {
+        return;
+    }
+
     /**
      * {@inheritdoc}
      */