diff --git a/src/infrastructure/storage/future/QueryFuture.php b/src/infrastructure/storage/future/QueryFuture.php --- a/src/infrastructure/storage/future/QueryFuture.php +++ b/src/infrastructure/storage/future/QueryFuture.php @@ -51,7 +51,7 @@ } public function isReady() { - if ($this->result !== null || $this->exception) { + if ($this->canResolve()) { return true; } @@ -105,7 +105,7 @@ $this->processResults($this->conn->resolveAsyncQueries($conns, $asyncs)); - if ($this->result !== null || $this->exception) { + if ($this->canResolve()) { return true; } return false;