Add App::terminate() stream support

src/App.php

@@ -25,6 +25,7 @@
 use Nyholm\Psr7Server\ServerRequestCreator;
 use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\ServerRequestInterface;
+use Psr\Http\Message\StreamInterface;
 use Psr\Log\LoggerInterface;
 
 class App
@@ -394,7 +395,7 @@ public function setResponseHeader(string $name, string $value): self
      * directly, instead call it form Callback, JsCallback or similar
      * other classes.
      *
-     * @param string|array $output Array type is supported only for JSON response
+     * @param string|array|StreamInterface $output Array type is supported only for JSON response
      *
      * @return never
      */
@@ -405,7 +406,10 @@ public function terminate($output = ''): void
             throw new Exception('Content type must be always set');
         }
 
-        if ($type === 'application/json') {
+        if ($output instanceof StreamInterface) {
+            $this->response = $this->response->withBody($output);
+            $this->outputResponse('');
+        } elseif ($type === 'application/json') {
             if (is_string($output)) {
                 $output = $this->decodeJson($output);
             }
@@ -1128,7 +1132,11 @@ protected function outputResponse(string $data): void
             return;
         }
 
-        $this->response->getBody()->write($data);
+        $stream = $this->response->getBody();
+        if ($data !== '' && $stream->isWritable()) {
+            $stream->write($data);
+        }
+
         $this->emitResponse();
     }
 

tests/AppTest.php

@@ -7,6 +7,8 @@
 use Atk4\Core\Phpunit\TestCase;
 use Atk4\Ui\Exception\LateOutputError;
 use Atk4\Ui\HtmlTemplate;
+use Nyholm\Psr7\Factory\Psr17Factory;
+use Psr\Http\Message\ServerRequestInterface;
 
 class AppTest extends TestCase
 {
@@ -68,4 +70,22 @@ public function testUnexpectedOutputLateError(): void
             ob_end_clean();
         }
     }
+
+    /* throws headers already sent exception so not sure how to write this test for stream output
+    public function testStreamResponse(): void
+    {
+        $app = $this->createApp();
+
+        ob_start();
+
+        $content = 'Hello, world!';
+        $factory = new Psr17Factory();
+        $stream = $factory->createStream($content);
+        $app->setResponseHeader('Content-Type', 'text/html');
+        $app->terminate($stream); // @todo headers already sent
+
+        static::assertSame($content, ob_get_contents());
+        ob_end_clean();
+    }
+    */
 }