asyncphp / icicle-database

tests/ManagerFactoryTest.php

Spacing +2 added lines, -2 removed lines

@@ -14,7 +14,7 @@ 
 {
     public function testInsert()
     {
-        Coroutine\create(function () {
+        Coroutine\create(function() {
             $factory = new ManagerFactory();
 
             $manager = $factory->create([
@@ -52,7 +52,7 @@ 
      */
     private function assertEqualsAfterDelay($delay, $expected, $actual)
     {
-        Loop\timer($delay, function () use ($expected, $actual) {
+        Loop\timer($delay, function() use ($expected, $actual) {
             $this->assertEquals($expected, $actual);
             Loop\stop();
         });

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

@@ -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();
                 });