diff --git a/System/Pool/ClientsPool.php b/System/Pool/ClientsPool.php index 1b3609ae..933d30ef 100644 --- a/System/Pool/ClientsPool.php +++ b/System/Pool/ClientsPool.php @@ -81,6 +81,9 @@ class ClientsPool extends Component { if (env('state') == 'exit') { Timer::clear($this->creates); + foreach (static::$_connections as $channel) { + $this->flush($channel, 0); + } $this->creates = -1; } else { $this->heartbeat_flush();