@@ -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 |
@@ -130,7 +130,7 @@ |
||
130 | 130 | * |
131 | 131 | * @param mixed $value |
132 | 132 | * |
133 | - * @return mixed |
|
133 | + * @return string |
|
134 | 134 | */ |
135 | 135 | public function escape($value) |
136 | 136 | { |
@@ -74,7 +74,7 @@ discard block |
||
74 | 74 | */ |
75 | 75 | public function first() |
76 | 76 | { |
77 | - return Coroutine\create(function () { |
|
77 | + return Coroutine\create(function() { |
|
78 | 78 | $rows = (yield $this->limit(1)->get()); |
79 | 79 | yield reset($rows); |
80 | 80 | }); |
@@ -85,7 +85,7 @@ discard block |
||
85 | 85 | */ |
86 | 86 | public function get() |
87 | 87 | { |
88 | - return Coroutine\create(function () { |
|
88 | + return Coroutine\create(function() { |
|
89 | 89 | $builder = $this->applyOperationsTo($this->builder); |
90 | 90 | |
91 | 91 | yield $this->connector->query( |
@@ -105,7 +105,7 @@ discard block |
||
105 | 105 | |
106 | 106 | $pattern = "/\\:([_0-9a-zA-Z]+)/"; |
107 | 107 | |
108 | - $replacement = function ($matches) use ($values) { |
|
108 | + $replacement = function($matches) use ($values) { |
|
109 | 109 | return $this->quote($values[$matches[1]]); |
110 | 110 | }; |
111 | 111 | |
@@ -129,7 +129,7 @@ discard block |
||
129 | 129 | */ |
130 | 130 | public function insert(array $data) |
131 | 131 | { |
132 | - return Coroutine\create(function () use ($data) { |
|
132 | + return Coroutine\create(function() use ($data) { |
|
133 | 133 | $builder = $this->builder->insert($data); |
134 | 134 | $builder = $this->applyOperationsTo($builder); |
135 | 135 | |
@@ -161,7 +161,7 @@ discard block |
||
161 | 161 | */ |
162 | 162 | public function update(array $data) |
163 | 163 | { |
164 | - return Coroutine\create(function () use ($data) { |
|
164 | + return Coroutine\create(function() use ($data) { |
|
165 | 165 | $builder = $this->builder->update($data); |
166 | 166 | $builder = $this->applyOperationsTo($builder); |
167 | 167 | |
@@ -176,7 +176,7 @@ discard block |
||
176 | 176 | */ |
177 | 177 | public function delete() |
178 | 178 | { |
179 | - return Coroutine\create(function () { |
|
179 | + return Coroutine\create(function() { |
|
180 | 180 | $builder = $this->builder->delete(); |
181 | 181 | $builder = $this->applyOperationsTo($builder); |
182 | 182 |
@@ -14,7 +14,7 @@ discard block |
||
14 | 14 | { |
15 | 15 | public function testInsert() |
16 | 16 | { |
17 | - Coroutine\create(function () { |
|
17 | + Coroutine\create(function() { |
|
18 | 18 | $factory = new ManagerFactory(); |
19 | 19 | |
20 | 20 | $manager = $factory->create([ |
@@ -52,7 +52,7 @@ discard block |
||
52 | 52 | */ |
53 | 53 | private function assertEqualsAfterDelay($delay, $expected, $actual) |
54 | 54 | { |
55 | - Loop\timer($delay, function () use ($expected, $actual) { |
|
55 | + Loop\timer($delay, function() use ($expected, $actual) { |
|
56 | 56 | $this->assertEquals($expected, $actual); |
57 | 57 | Loop\stop(); |
58 | 58 | }); |