fixing response chunk swicther and change core class to final class

composer.json

@@ -15,7 +15,9 @@
     "require": {
         "php": ">=8.2",
         "dflydev/fig-cookies": "^3.1",
-        "nyholm/psr7": "^1.8"
+        "psr/http-message": "^2.0",
+        "psr/http-factory": "^1.0",
+        "httpsoft/http-message": "^1.1"
     },
     "require-dev": {
         "phpstan/phpstan": "^1.10",
@@ -25,5 +27,4 @@
     "scripts": {
         "analyse": "phpstan analyse"
     }
-
 }

src/Contract/BridgeFactoryApp.php

@@ -1,16 +1,12 @@
 <?php
 
 namespace Xel\Psr7bridge\Contract;
-use Nyholm\Psr7\Factory\Psr17Factory;
 use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\ServerRequestInterface;
 use Swoole\Http\Request as SwooleRequest;
 use Swoole\Http\Response as SwooleResponse;
-use Xel\Psr7bridge\PsrFactory;
-
 interface BridgeFactoryApp
 {
-
     public function connectRequest
     (
         SwooleRequest $request,

src/Core/RequestMapper.php

@@ -10,12 +10,12 @@
 use Psr\Http\Message\UploadedFileInterface;
 use RuntimeException;
 
-class RequestMapper
+final class RequestMapper
 {
     private ServerRequestFactoryInterface $serverRequestFactory;
     private StreamFactoryInterface $streamFactory;
     private UploadedFileFactoryInterface $uploadedFileFactory;
-    public array $uploadFile;
+    public array $uploadFile =[];
 
     public function __invoke
     (
@@ -63,11 +63,11 @@ public function serverMap
 
         // ? Map List
         return $mapper
-            ->withCookieParams($swooleCookie ??[])
-            ->withQueryParams($swooleQueryParam ?? [])
-            ->withParsedBody($swooleParseBody ?? [])
+            ->withCookieParams($swooleCookie)
+            ->withQueryParams($swooleQueryParam)
+            ->withParsedBody($swooleParseBody)
             ->withBody($this->streamFactory->createStream($rawContent))
-            ->withUploadedFiles($this->uploadFile ?? [])
+            ->withUploadedFiles($this->uploadFile)
             ->withProtocolVersion('1.1');
     }
 
@@ -76,7 +76,7 @@ private function createUploadedFileStream(array $files): StreamInterface|Uploade
         try {
             $stream = $this->streamFactory->createStreamFromFile($files['tmp_name']);
         } catch (RuntimeException) {
-            $stream = $this->streamFactory->createStream();
+            return $this->streamFactory->createStream();
         }
 
         return $this->uploadedFileFactory->createUploadedFile(

src/Core/ResponseMapper.php

@@ -5,10 +5,13 @@
 use Dflydev\FigCookies\SetCookies;
 use Psr\Http\Message\ResponseInterface;
 use Swoole\Http\Response as SwooleResponse;
-class ResponseMapper
+
+final class ResponseMapper
 {
     private ResponseInterface $psr7Response;
     private SwooleResponse $swooleResponse;
+
+    const THRESHOLD = 8192;
     public function __invoke
     (
         ResponseInterface $psr7Response,
@@ -54,22 +57,31 @@ private function cookieMap(swooleResponse $swooleResponse, SetCookie $cookie): v
     public function mapBody(ResponseInterface $response, SwooleResponse $swooleResponse): void
     {
         $body = $response->getBody();
+
+        $allocChunk = $body->getSize();
+
+        if ($allocChunk > self::THRESHOLD) {
+            $this->chuckAllocator($body,$allocChunk,$swooleResponse);
+        }
+
         if($body->isSeekable()){
             $body->rewind();
         }
 
-        $allocChunk = $body->getSize();
-        $getSizeChunk = $allocChunk > 3000 ? intval($allocChunk * 0.5 ) : $allocChunk;
+        $swooleResponse->end($body->getContents());
+    }
 
+    private function chuckAllocator($body,$allocChunk, $swooleResponse): void
+    {
+        $getSizeChunk = intval($allocChunk * 0.5);
         while (!$body->eof()) {
             $chunk = $body->read($getSizeChunk);
             if ($chunk === '') {
                 break;
             }
             $swooleResponse->write($chunk);
+            $swooleResponse->end();
         }
-
-        $swooleResponse->end();
     }
 
 }