asyncphp / icicle-database

src/Connector/MySQLConnector.php

Spacing +2 added lines, -2 removed lines

@@ -86,7 +86,7 @@ 
             $this->connection,
         ];
 
-        $outer = Loop\periodic($this->poll, function () use (&$outer, $links, $errors, $rejects, $query, $deferred) {
+        $outer = Loop\periodic($this->poll, function() use (&$outer, $links, $errors, $rejects, $query, $deferred) {
             if ($this->ready) {
                 $this->ready = false;
                 $outer->stop();
@@ -98,7 +98,7 @@ 
                     return $deferred->reject($this->connection->error);
                 }
 
-                $inner = Loop\periodic($this->poll, function () use (&$inner, $links, $errors, $rejects, $deferred) {
+                $inner = Loop\periodic($this->poll, function() use (&$inner, $links, $errors, $rejects, $deferred) {
                     if (mysqli_poll($links, $errors, $rejects, $this->poll)) {
                         $inner->stop();
 

Doc Comments +1 added lines, -1 removed lines

@@ -130,7 +130,7 @@
      *
      * @param mixed $value
      *
-     * @return mixed
+     * @return string
      */
     public function escape($value)
     {

src/Manager.php

Spacing +6 added lines, -6 removed lines

@@ -48,7 +48,7 @@ 
      */
     public function first()
     {
-        return Coroutine\create(function () {
+        return Coroutine\create(function() {
             $rows = (yield $this->limit(1)->get());
             yield reset($rows);
         });
@@ -59,7 +59,7 @@ 
      */
     public function get()
     {
-        return Coroutine\create(function () {
+        return Coroutine\create(function() {
             yield $this->connector->query(
                 $this->interpolate($this->builder->build())
             );
@@ -75,7 +75,7 @@ 
     {
         list($statement, $values) = $build;
 
-        return preg_replace_callback("/\\:([_0-9a-zA-Z]+)/", function ($matches) use ($values) {
+        return preg_replace_callback("/\\:([_0-9a-zA-Z]+)/", function($matches) use ($values) {
             return "'" . $this->connector->escape($values[$matches[1]]) . "'";
         }, $statement);
     }
@@ -87,7 +87,7 @@ 
      */
     public function insert(array $data)
     {
-        return Coroutine\create(function () use ($data) {
+        return Coroutine\create(function() use ($data) {
             yield $this->connector->query(
                 $this->interpolate($this->builder->insert($data)->build())
             );
@@ -101,7 +101,7 @@ 
      */
     public function update(array $data)
     {
-        return Coroutine\create(function () use ($data) {
+        return Coroutine\create(function() use ($data) {
             yield $this->connector->query(
                 $this->interpolate($this->builder->update($data)->build())
             );
@@ -113,7 +113,7 @@ 
      */
     public function delete()
     {
-        return Coroutine\create(function () {
+        return Coroutine\create(function() {
             yield $this->connector->query(
                 $this->interpolate($this->builder->delete()->build())
             );