Enforce stream request/response body stream

Author: WyriHaximus

src/ReactMiddleware.php

@@ -4,6 +4,7 @@
 
 namespace ReactParallel\Psr15Adapter;
 
+use Ancarda\Psr7\StringStream\ReadOnlyStringStream;
 use parallel\Channel;
 use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\ServerRequestInterface;
@@ -39,14 +40,16 @@ public function __construct(
 
     public function __invoke(ServerRequestInterface $request, callable $next): PromiseInterface
     {
+        $request = $request->withBody(new ReadOnlyStringStream((string) $request->getBody()));
+
         return new Promise(function (callable $resolve, callable $reject) use ($request, $next): void {
             $input  = new Channel(Channel::Infinite);
             $output = new Channel(Channel::Infinite);
 
             $this->streamFactory->single($output)->then(static function (string $request): ServerRequestInterface {
                 return unserialize($request);
             }, $reject)->then($next)->then(static function (ResponseInterface $response): string {
-                return serialize($response);
+                return serialize($response->withBody(new ReadOnlyStringStream((string) $response->getBody())));
             }, $reject)->then(static function (string $response) use ($input): void {
                 $input->send($response);
             }, $reject);