Add support for streamed response

Author: danizord

Factory/HttpFoundationFactory.php

@@ -13,13 +13,14 @@
 
 use Psr\Http\Message\ServerRequestInterface;
 use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\StreamInterface;
 use Psr\Http\Message\UploadedFileInterface;
 use Psr\Http\Message\UriInterface;
 use Symfony\Bridge\PsrHttpMessage\HttpFoundationFactoryInterface;
 use Symfony\Component\HttpFoundation\Cookie;
 use Symfony\Component\HttpFoundation\File\UploadedFile;
 use Symfony\Component\HttpFoundation\Request;
-use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\HttpFoundation\StreamedResponse;
 
 /**
  * {@inheritdoc}
@@ -28,6 +29,19 @@
  */
 class HttpFoundationFactory implements HttpFoundationFactoryInterface
 {
+    /**
+     * @var int Maximum output buffering size for each iteration when sending the response.
+     */
+    private $responseBufferMaxLength;
+
+    /**
+     * @param int $responseBufferMaxLength
+     */
+    public function __construct($responseBufferMaxLength = 8192)
+    {
+        $this->responseBufferMaxLength = $responseBufferMaxLength;
+    }
+
     /**
      * {@inheritdoc}
      */
@@ -140,11 +154,12 @@ protected function getTemporaryPath()
      */
     public function createResponse(ResponseInterface $psrResponse)
     {
-        $response = new Response(
-            $psrResponse->getBody()->__toString(),
+        $response = new StreamedResponse(
+            $this->createStreamedResponseCallback($psrResponse->getBody()),
             $psrResponse->getStatusCode(),
             $psrResponse->getHeaders()
         );
+
         $response->setProtocolVersion($psrResponse->getProtocolVersion());
 
         foreach ($psrResponse->getHeader('Set-Cookie') as $cookie) {
@@ -226,4 +241,30 @@ private function createCookie($cookie)
             isset($cookieHttpOnly)
         );
     }
+
+    /**
+     * @param StreamInterface $body
+     *
+     * @return callable
+     */
+    private function createStreamedResponseCallback(StreamInterface $body)
+    {
+        $responseBufferMaxLength = $this->responseBufferMaxLength;
+
+        return function () use ($body, $responseBufferMaxLength) {
+            if ($body->isSeekable()) {
+                $body->rewind();
+            }
+
+            if (! $body->isReadable()) {
+                echo $body;
+
+                return;
+            }
+
+            while (! $body->eof()) {
+                echo $body->read($responseBufferMaxLength);
+            }
+        };
+    }
 }

Tests/Factory/HttpFoundationFactoryTest.php

@@ -231,7 +231,11 @@ public function testCreateResponse()
         $this->assertTrue($cookies[2]->isSecure());
         $this->assertTrue($cookies[2]->isHttpOnly());
 
-        $this->assertEquals('The response body', $symfonyResponse->getContent());
+        ob_start();
+        $symfonyResponse->sendContent();
+        $sentContent = ob_get_clean();
+
+        $this->assertEquals('The response body', $sentContent);
         $this->assertEquals(200, $symfonyResponse->getStatusCode());
     }
 }

Tests/Fixtures/Stream.php

@@ -19,6 +19,7 @@
 class Stream implements StreamInterface
 {
     private $stringContent;
+    private $eof = true;
 
     public function __construct($stringContent = '')
     {
@@ -49,12 +50,12 @@ public function tell()
 
     public function eof()
     {
-        return true;
+        return $this->eof;
     }
 
     public function isSeekable()
     {
-        return false;
+        return true;
     }
 
     public function seek($offset, $whence = SEEK_SET)
@@ -63,6 +64,7 @@ public function seek($offset, $whence = SEEK_SET)
 
     public function rewind()
     {
+        $this->eof = false;
     }
 
     public function isWritable()
@@ -81,6 +83,8 @@ public function isReadable()
 
     public function read($length)
     {
+        $this->eof = true;
+
         return $this->stringContent;
     }