asyncphp / icicle-database

src/Connector/DoormanConnector.php

Spacing +6 added lines, -6 removed lines

@@ -62,21 +62,21 @@ 
         $this->connectRemit($config);
         $this->connectDoorman($config);
 
-        $this->server->addListener("r", function ($result, $id) {
+        $this->server->addListener("r", function($result, $id) {
             if (isset($this->deferred[$id])) {
                 $this->deferred[$id]->resolve($result);
                 unset($this->deferred[$id]);
             }
         });
 
-        $this->server->addListener("e", function ($error, $id) {
+        $this->server->addListener("e", function($error, $id) {
             if (isset($this->deferred[$id])) {
                 $this->deferred[$id]->reject($error);
                 unset($this->deferred[$id]);
             }
         });
 
-        Loop\periodic(0, function () {
+        Loop\periodic(0, function() {
             $this->server->tick();
         });
 
@@ -161,7 +161,7 @@ 
         $client = $config["remit"]["client"];
 
         if ($config["remit"]["driver"] === "zeromq") {
-            $task = new ProcessCallbackTask(function () use ($config, $server, $client) {
+            $task = new ProcessCallbackTask(function() use ($config, $server, $client) {
                 $config = array_merge([
                     "host" => "127.0.0.1",
                     "port" => 3306,
@@ -202,11 +202,11 @@ 
                     )
                 );
 
-                $remitServer->addListener("q", function ($query, $values, $id) use ($remitClient, $connection) {
+                $remitServer->addListener("q", function($query, $values, $id) use ($remitClient, $connection) {
                     $remitClient->emit("r", [$connection->fetchAll($query, $values), $id]);
                 });
 
-                Loop\periodic(0, function () use ($remitServer) {
+                Loop\periodic(0, function() use ($remitServer) {
                     $remitServer->tick();
                 });