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