NDJsonDecoder has a default max length of 65536 characters. We have an RPC object larger than this so allow the Decoder to have a configurable max length

Author: lucasnetau

src/React/Decoder.php

@@ -20,22 +20,23 @@
 class Decoder extends EventEmitter implements ReadableStreamInterface
 {
     /**
-     * @var \Clue\React\NDJson\Decoder
+     * @var NDJsonDecoder
      */
-    protected $ndjson_decoder;
+    protected NDJsonDecoder $ndjson_decoder;
 
     /**
      * @var bool Flag if stream is closed
      */
-    private $closed = false;
+    private bool $closed = false;
 
     /**
      * Decoder constructor.
      * @param ReadableStreamInterface $input
+     * @param int $maxLength Max length of a JSON line
      */
-    public function __construct(ReadableStreamInterface $input)
+    public function __construct(ReadableStreamInterface $input, int $maxLength = 65536)
     {
-        $this->ndjson_decoder = new NDJsonDecoder($input, true);
+        $this->ndjson_decoder = new NDJsonDecoder($input, true, 512, 0, $maxLength);
 
         $this->ndjson_decoder->on('data', array($this, 'handleData'));
         $this->ndjson_decoder->on('end', array($this, 'handleEnd'));
@@ -46,7 +47,7 @@ public function __construct(ReadableStreamInterface $input)
     /**
      * Close the stream
      */
-    public function close()
+    public function close() : void
     {
         $this->closed = true;
         $this->ndjson_decoder->close();
@@ -57,23 +58,23 @@ public function close()
     /**
      * @return bool
      */
-    public function isReadable()
+    public function isReadable() : bool
     {
         return $this->ndjson_decoder->isReadable();
     }
 
     /**
      * Pause
      */
-    public function pause()
+    public function pause() : void
     {
         $this->ndjson_decoder->pause();
     }
 
     /**
      * Resume
      */
-    public function resume()
+    public function resume() : void
     {
         $this->ndjson_decoder->resume();
     }