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]);
                 });