fix: avoid panic on empty result

Signed-off-by: gfanton <8671905+gfanton@users.noreply.github.com>
This commit is contained in:
gfanton 2022-09-06 10:48:44 +02:00
parent 2a4b093b3a
commit 7f8acdc3c4

View File

@ -362,10 +362,13 @@ func (rp *rendezvousPoint) DiscoverSubscribe(ctx context.Context, ns string, ser
for {
select {
case result, ok := <-regCh:
if !ok {
return
}
ch <- result.Peer
case <-ctx.Done():
return
case result := <-regCh:
ch <- result.Peer
}
}
}()