@@ -86,7 +86,7 @@ discard block |
||
86 | 86 | $this->connection, |
87 | 87 | ]; |
88 | 88 | |
89 | - $outer = Loop\periodic($this->poll, function () use (&$outer, $links, $errors, $rejects, $query, $deferred) { |
|
89 | + $outer = Loop\periodic($this->poll, function() use (&$outer, $links, $errors, $rejects, $query, $deferred) { |
|
90 | 90 | if ($this->ready) { |
91 | 91 | $this->ready = false; |
92 | 92 | $outer->stop(); |
@@ -98,7 +98,7 @@ discard block |
||
98 | 98 | return $deferred->reject($this->connection->error); |
99 | 99 | } |
100 | 100 | |
101 | - $inner = Loop\periodic($this->poll, function () use (&$inner, $links, $errors, $rejects, $deferred) { |
|
101 | + $inner = Loop\periodic($this->poll, function() use (&$inner, $links, $errors, $rejects, $deferred) { |
|
102 | 102 | if (mysqli_poll($links, $errors, $rejects, $this->poll)) { |
103 | 103 | $inner->stop(); |
104 | 104 |
@@ -31,7 +31,7 @@ |
||
31 | 31 | * @param string $method |
32 | 32 | * @param array $parameters |
33 | 33 | * |
34 | - * @return mixed |
|
34 | + * @return Manager |
|
35 | 35 | */ |
36 | 36 | public function __call($method, array $parameters = []) |
37 | 37 | { |
@@ -48,7 +48,7 @@ discard block |
||
48 | 48 | */ |
49 | 49 | public function get() |
50 | 50 | { |
51 | - return Coroutine\create(function () { |
|
51 | + return Coroutine\create(function() { |
|
52 | 52 | list($statement, $bindings) = $this->builder->build(); |
53 | 53 | |
54 | 54 | // TODO |
@@ -62,7 +62,7 @@ discard block |
||
62 | 62 | */ |
63 | 63 | public function first() |
64 | 64 | { |
65 | - return Coroutine\create(function () { |
|
65 | + return Coroutine\create(function() { |
|
66 | 66 | $rows = (yield $this->limit(1)->get()); |
67 | 67 | |
68 | 68 | if (count($rows) > 0) { |