This commit is contained in:
2021-10-20 16:54:32 +08:00
parent a2f0430b94
commit a98807c378
+2 -6
View File
@@ -218,12 +218,8 @@ class Pool extends Component
if (!isset(static::$_connections[$name])) {
return;
}
var_dump(static::$_connections[$name]);
/** @var Channel|SplQueue $connection */
foreach (static::$_connections[$name] as $connection) {
$client = $connection->pop();
while (static::$_connections[$name]->length() > 0) {
$client = static::$_connections[$name]->pop();
if ($client instanceof StopHeartbeatCheck) {
$client->stopHeartbeatCheck();
}