diff --git a/client.go b/client.go index ca19cf1..8a42219 100644 --- a/client.go +++ b/client.go @@ -204,6 +204,7 @@ func discoverAsync(ctx context.Context, ns string, s inet.Stream, ch chan Regist } if len(regs) < batch { + // TODO adaptive backoff for heavily loaded rendezvous points select { case <-time.After(2 * time.Minute): case <-ctx.Done():