|
@@ 94-97 (lines=4) @@
|
| 91 |
|
|
| 92 |
|
$result = $this->connection->query($query, MYSQLI_ASYNC); |
| 93 |
|
|
| 94 |
|
if ($result === false) { |
| 95 |
|
$this->ready = true; |
| 96 |
|
return $deferred->reject($this->connection->error); |
| 97 |
|
} |
| 98 |
|
|
| 99 |
|
$inner = Loop\periodic($this->poll, function () use (&$inner, $links, $errors, $rejects, $deferred) { |
| 100 |
|
if (mysqli_poll($links, $errors, $rejects, $this->poll)) { |
|
@@ 105-108 (lines=4) @@
|
| 102 |
|
|
| 103 |
|
$result = $this->connection->reap_async_query(); |
| 104 |
|
|
| 105 |
|
if ($result === false) { |
| 106 |
|
$this->ready = true; |
| 107 |
|
return $deferred->reject($this->connection->error); |
| 108 |
|
} |
| 109 |
|
|
| 110 |
|
if ($result === true) { |
| 111 |
|
$this->ready = true; |