diff --git a/src/Connection/ConnectionLimitingPool.php b/src/Connection/ConnectionLimitingPool.php index b51fd749..54af3472 100644 --- a/src/Connection/ConnectionLimitingPool.php +++ b/src/Connection/ConnectionLimitingPool.php @@ -82,6 +82,17 @@ public function __clone() $this->openConnectionCount = 0; } + public function __destruct() + { + foreach ($this->connections as $connectionFutures) { + foreach ($connectionFutures as $connectionFuture) { + $connectionFuture->map(static function (Connection $connection): void { + $connection->close(); + }); + } + } + } + public function getTotalConnectionAttempts(): int { return $this->totalConnectionAttempts;