From fca9f5ed9c5175ed32fe3a5779e571e2c3bd02d4 Mon Sep 17 00:00:00 2001
From: Mark Friedrich <exodus4d@users.noreply.github.com>
Date: Tue, 7 May 2019 00:10:30 +0200
Subject: [PATCH] - fixed broken JSON payload data on large JSON objects

---
 app/Socket/TcpSocket.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/app/Socket/TcpSocket.php b/app/Socket/TcpSocket.php
index fdcea64..cf2f229 100644
--- a/app/Socket/TcpSocket.php
+++ b/app/Socket/TcpSocket.php
@@ -224,7 +224,7 @@ class TcpSocket {
                 $promise = Promise\Stream\first($streamDecoded);
 
                 // register on('data') for main input stream
-                $connection->once('data', function ($chunk) use ($stream) {
+                $connection->on('data', function ($chunk) use ($stream) {
                     // send current data chunk to processing stream -> resolves promise
                     $stream->emit('data', [$chunk]);
                 });