nsq/nsqphp
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Unset previous producers on lookup newer

Browse Source
This commit is contained in:
Konstantin Grachev
2021-09-18 23:01:56 +03:00
parent 2c07fb1aca
commit 155e896543
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/Lookup.php
View File

@@ -206,6 +206,7 @@ final class Lookup
/** @var Lookup\Response[] $responses */ /** @var Lookup\Response[] $responses */
$responses = yield $promises; $responses = yield $promises;
$producers = [];
foreach ($responses as $response) { foreach ($responses as $response) {
if (($deferred = ($this->producers[$topic] ?? null)) instanceof Deferred) { if (($deferred = ($this->producers[$topic] ?? null)) instanceof Deferred) {
$deferred->resolve($response->producers); $deferred->resolve($response->producers);
@@ -213,9 +214,10 @@ final class Lookup
} }
foreach ($response->producers as $producer) { foreach ($response->producers as $producer) {
$this->producers[$topic][$producer->toTcpUri()] = $producer; $producers[$producer->toTcpUri()] = $producer;
} }
} }
$this->producers[$topic] = $producers;
yield delay($this->config->pollingInterval); yield delay($this->config->pollingInterval);
} }