asiries335 / redis-streams-php

src/Stream.php

Spacing +1 added lines, -1 removed lines

@@ -196,7 +196,7 @@
 
         $loop->addPeriodicTimer(
             Constants::TIME_TICK_INTERVAL,
-            function () use ($closure, $messageHydrate, $loop) {
+            function() use ($closure, $messageHydrate, $loop) {
                 $transporter = new StreamCommandCallTransporter(
                     [
                         'command' => Constants::COMMAND_XRANGE,

tests/Unit/ClientTest.php

Spacing +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
      */
     public function setUp() : void
     {
-        $connector  = \Mockery::mock(ClientRedisStreamPhpInterface::class);
+        $connector = \Mockery::mock(ClientRedisStreamPhpInterface::class);
         $this->client = new Client($connector);
     }
 

src/Consumer/DemoConsumer.php

Spacing +1 added lines, -1 removed lines

@@ -6,6 +6,6 @@
 {
 
     public function handle($payload) {
-        echo 'привет я Demo Consumer - ' .  $payload;
+        echo 'привет я Demo Consumer - ' . $payload;
     }
 }
\ No newline at end of file

src/Server/TcpServer.php

Spacing +2 added lines, -2 removed lines

@@ -45,11 +45,11 @@
 
         $this->tcpServer = new \React\Socket\TcpServer($ip . ':' . $port);
 
-        $this->tcpServer->on('connection', function (ConnectionInterface $connection) {
+        $this->tcpServer->on('connection', function(ConnectionInterface $connection) {
 
             $connection->pipe($connection);
 
-            $connection->on('data', function ($payload) {
+            $connection->on('data', function($payload) {
                 foreach ($this->consumers as $consumer) {
                     $consumer->handle($payload);
                 }