asyncphp / icicle-database

src/Manager.php

Spacing +5 added lines, -5 removed lines

@@ -85,7 +85,7 @@ 
      */
     public function first()
     {
-        return Coroutine\create(function () {
+        return Coroutine\create(function() {
             $rows = (yield $this->limit(1)->get());
             yield reset($rows);
         });
@@ -96,7 +96,7 @@ 
      */
     public function get()
     {
-        return Coroutine\create(function () {
+        return Coroutine\create(function() {
             $builder = $this->applyOperationsTo($this->builder);
 
             list($statement, $values) = $builder->build();
@@ -111,7 +111,7 @@ 
      */
     public function insert(array $data)
     {
-        return Coroutine\create(function () use ($data) {
+        return Coroutine\create(function() use ($data) {
             $builder = $this->builder->insert($data);
             $builder = $this->applyOperationsTo($builder);
 
@@ -142,7 +142,7 @@ 
      */
     public function update(array $data)
     {
-        return Coroutine\create(function () use ($data) {
+        return Coroutine\create(function() use ($data) {
             $builder = $this->builder->update($data);
             $builder = $this->applyOperationsTo($builder);
 
@@ -156,7 +156,7 @@ 
      */
     public function delete()
     {
-        return Coroutine\create(function () {
+        return Coroutine\create(function() {
             $builder = $this->builder->delete();
             $builder = $this->applyOperationsTo($builder);
 

src/Connector/DoormanConnector.php

Spacing +6 added lines, -6 removed lines

@@ -67,21 +67,21 @@ 
         $this->connectRemit($config);
         $this->connectDoorman($config);
 
-        $this->server->addListener("result", function ($result, $id) {
+        $this->server->addListener("result", function($result, $id) {
             if (isset($this->deferred[$id])) {
                 $this->deferred[$id]->resolve($result);
                 unset($this->deferred[$id]);
             }
         });
 
-        $this->server->addListener("error", function ($error, $id) {
+        $this->server->addListener("error", 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->manager->tick();
             $this->server->tick();
         });
@@ -168,7 +168,7 @@ 
 
         if ($config["remit"]["driver"] === "zeromq") {
             foreach ($config["remit"]["clients"] as $i => $client) {
-                $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,
@@ -209,11 +209,11 @@ 
                         )
                     );
 
-                    $remitServer->addListener("query", function ($query, $values, $id) use ($remitClient, $connection) {
+                    $remitServer->addListener("query", function($query, $values, $id) use ($remitClient, $connection) {
                         $remitClient->emit("result", [$connection->fetchAll($query, $values), $id]);
                     });
 
-                    Loop\periodic(0, function () use ($remitServer) {
+                    Loop\periodic(0, function() use ($remitServer) {
                         $remitServer->tick();
                     });