diff --git a/System/Abstracts/Pool.php b/System/Abstracts/Pool.php index bf5b654d..2d58281f 100644 --- a/System/Abstracts/Pool.php +++ b/System/Abstracts/Pool.php @@ -127,11 +127,10 @@ abstract class Pool extends Component public function createConnect(array $config, string $coroutineName, callable $createHandler): PDO|Redis|false { if (Context::hasContext('create:connect:' . $coroutineName)) { - while (!($client = Context::hasContext($coroutineName))){ + while (!($client = Context::getContext($coroutineName))){ var_dump($client); } - var_dump($client); - return true; + return $client; } Context::setContext('create:connect:' . $coroutineName, 1); @@ -139,7 +138,7 @@ abstract class Pool extends Component Context::deleteId('create:connect:' . $coroutineName); - return $client; + return Context::setContext($coroutineName, $client); } diff --git a/System/Pool/Connection.php b/System/Pool/Connection.php index 5f413564..5a9d37bf 100644 --- a/System/Pool/Connection.php +++ b/System/Pool/Connection.php @@ -151,10 +151,7 @@ class Connection extends Pool return Context::getContext($coroutineName); } if (!$this->hasItem($coroutineName)) { - if (($client = $this->newClient($config, $coroutineName)) == true) { - return Context::getContext($coroutineName); - } - return Context::setContext($coroutineName, $client); + return $this->newClient($config, $coroutineName); } [$time, $connections] = $this->get($coroutineName); if (!($connections instanceof PDO)) { diff --git a/System/Pool/Redis.php b/System/Pool/Redis.php index ceec757d..1245fe65 100644 --- a/System/Pool/Redis.php +++ b/System/Pool/Redis.php @@ -47,10 +47,7 @@ class Redis extends Pool return Context::getContext($coroutineName); } if (!$this->hasItem($coroutineName)) { - if (($client = $this->newClient($config, $coroutineName)) == true) { - return Context::getContext($coroutineName); - } - return Context::setContext($coroutineName, $client); + return $this->newClient($config, $coroutineName); } [$time, $clients] = $this->get($coroutineName); if ($clients === null) {