Test streamed response (#157)

* Test streamed response

* Update mock

Author: barryvdh

tests/RoadRunnerClientTest.php

@@ -12,6 +12,7 @@
 use Mockery;
 use Psr\Http\Message\ResponseInterface;
 use Spiral\RoadRunner\Http\PSR7Worker;
+use Symfony\Component\HttpFoundation\StreamedResponse;
 
 class RoadRunnerClientTest extends TestCase
 {
@@ -46,6 +47,23 @@ public function test_respond_method_send_response_to_roadrunner()
         ]), new OctaneResponse(new Response('Hello World', 200)));
     }
 
+    /** @doesNotPerformAssertions @test */
+    public function test_respond_method_send_streamed_response_to_roadrunner()
+    {
+        $client = new RoadRunnerClient($psr7Client = Mockery::mock(PSR7Worker::class));
+
+        $psr7Request = (new ServerRequestFactory)->createServerRequest('GET', '/home');
+        $psr7Request = $psr7Request->withQueryParams(['name' => 'Taylor']);
+
+        $psr7Client->shouldReceive('respond')->once()->with(Mockery::type(ResponseInterface::class));
+
+        $client->respond(new RequestContext([
+            'psr7Request' => $psr7Request,
+        ]), new OctaneResponse(new StreamedResponse(function () {
+            echo 'Hello World';
+        }, 200)));
+    }
+
     /** @doesNotPerformAssertions @test */
     public function test_error_method_sends_error_response_to_roadrunner()
     {

tests/SwooleClientTest.php

@@ -9,6 +9,7 @@
 use Laravel\Octane\RequestContext;
 use Laravel\Octane\Swoole\SwooleClient;
 use Mockery;
+use Symfony\Component\HttpFoundation\StreamedResponse;
 
 class SwooleClientTest extends TestCase
 {
@@ -133,6 +134,27 @@ public function test_respond_method_send_response_to_swoole()
         ]), new OctaneResponse(new Response('Hello World', 200, ['Content-Type' => 'text/html'])));
     }
 
+    /** @doesNotPerformAssertions @test */
+    public function test_respond_method_send_streamed_response_to_swoole()
+    {
+        $client = new SwooleClient;
+
+        $swooleResponse = Mockery::mock('Swoole\Http\Response');
+
+        $swooleResponse->shouldReceive('status')->once()->with(200);
+        $swooleResponse->shouldReceive('header')->once()->with('Cache-Control', 'no-cache, private');
+        $swooleResponse->shouldReceive('header')->once()->with('Content-Type', 'text/html');
+        $swooleResponse->shouldReceive('header')->once()->with('Date', Mockery::type('string'));
+        $swooleResponse->shouldReceive('write')->once()->with('Hello World');
+        $swooleResponse->shouldReceive('end')->once();
+
+        $client->respond(new RequestContext([
+            'swooleResponse' => $swooleResponse,
+        ]), new OctaneResponse(new StreamedResponse(function () {
+            echo 'Hello World';
+        }, 200, ['Content-Type' => 'text/html'])));
+    }
+
     /** @doesNotPerformAssertions @test */
     public function test_error_method_sends_error_response_to_swoole()
     {