carno-php / redis

src/Chips/Subscriber.php

Spacing +2 added lines, -2 removed lines

@@ -68,7 +68,7 @@ 
 
         $closed = $this->closed();
 
-        $closed->then(function () {
+        $closed->then(function() {
             $this->consumer && $this->consumer->close();
         });
 
@@ -88,7 +88,7 @@ 
      */
     private function acknowledge() : Promised
     {
-        ($this->acknowledge = Promise::deferred())->then(function () {
+        ($this->acknowledge = Promise::deferred())->then(function() {
             unset($this->acknowledge);
         });
         return $this->acknowledge;

src/Redis.php

Spacing +8 added lines, -8 removed lines

@@ -110,20 +110,20 @@ 
      */
     public function connect() : Promised
     {
-        $this->link->on('close', function () {
+        $this->link->on('close', function() {
             unset($this->link);
             $this->closed()->resolve();
         });
 
-        $this->link->on('message', function (SWRedis $c, array $recv) {
+        $this->link->on('message', function(SWRedis $c, array $recv) {
             $this->messaging($recv);
         });
 
-        return new Promise(function (Promised $promise) {
+        return new Promise(function(Promised $promise) {
             $executed = $this->link->connect(
                 $this->host,
                 $this->port,
-                static function (SWRedis $c, bool $success) use ($promise) {
+                static function(SWRedis $c, bool $success) use ($promise) {
                     $success
                         ? $promise->resolve()
                         : $promise->throw(new ConnectingException($c->errMsg, $c->errCode))
@@ -141,8 +141,8 @@ 
      */
     public function heartbeat() : Promised
     {
-        return new Promise(function (Promised $promised) {
-            $this->link->__call('ping', [function (SWRedis $c, $result) use ($promised) {
+        return new Promise(function(Promised $promised) {
+            $this->link->__call('ping', [function(SWRedis $c, $result) use ($promised) {
                 $result === false
                     ? $promised->reject()
                     : $promised->resolve()
@@ -179,12 +179,12 @@ 
             EXT::REMOTE_ENDPOINT => new Endpoint($this->named),
         ]);
 
-        $executor = function ($fn) use ($name, $arguments) {
+        $executor = function($fn) use ($name, $arguments) {
             array_push($arguments, $fn);
             $this->command($name, $arguments);
         };
 
-        $receiver = static function (SWRedis $c, $result) {
+        $receiver = static function(SWRedis $c, $result) {
             if ($result === false && $c->errCode > 0) {
                 throw new CommandException($c->errMsg, $c->errCode);
             } else {

src/Cluster.php

Spacing +1 added lines, -1 removed lines

@@ -83,7 +83,7 @@
             $dsn->option('execute', $this->timeout)
         );
 
-        return new Pool($this->options($endpoint), static function () use ($timeouts, $dsn, $vid) {
+        return new Pool($this->options($endpoint), static function() use ($timeouts, $dsn, $vid) {
             return new Redis(
                 sprintf('%s:%d', $dsn->host(), $dsn->port()),
                 $dsn->pass() ?: null,