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