Close channels when close socket. (#78)

swoole · Mar 14, 2023 · cf93625 · cf93625
1 parent f154746
commit cf93625
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/src/Client/SwooleClient.php b/src/Client/SwooleClient.php
@@ -56,6 +56,10 @@ public function connect(): void
     public function close(): bool
     {
         $this->connected = false;
+        foreach ($this->recvChannels as $channel) {
+            $channel->close();
+        }
+
         $this->recvChannels = [];
 
         return $this->socket->close();

diff --git a/src/Consumer/Consumer.php b/src/Consumer/Consumer.php
@@ -297,6 +297,10 @@ protected function fetchMessages(): void
         }
         $nodeId = key($this->fetchOptions);
         next($this->fetchOptions);
+        if (empty($this->fetchOptions)) {
+            // avoid dead cycle.
+            sleep(1);
+        }
         if (!$currentList) {
             return;
         }