@@ 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; |