Lookup fix cancelling topic watcher

This commit is contained in:
2021-09-15 01:35:26 +03:00
parent 47194b30f3
commit dbe312ddf1

View File

@ -89,7 +89,7 @@ final class Lookup
public function stop(): void
{
foreach ($this->running as $topic => $channels) {
foreach ($channels as $channel) {
foreach (array_keys($channels) as $channel) {
$this->unsubscribe($topic, $channel);
}
}
@ -176,6 +176,10 @@ final class Lookup
unset($this->running[$topic][$channel]);
if ([] === $this->running[$topic]) {
unset($this->running[$topic]);
}
$this->logger->info('Unsubscribed', compact('topic', 'channel'));
}