Set must reconnect = false only in error case

txix-open · Feb 13, 2024 · 2b57b07 · 2b57b07
1 parent af69986
commit 2b57b07
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/client.go b/client.go
@@ -89,7 +89,9 @@ func (s *Client) Run(ctx context.Context) error {
  case <-ctx.Done():
  return ctx.Err()
  case err := <-s.firstOccurredError:
- s.mustReconnect.Store(false)
+ if err != nil {
+ s.mustReconnect.Store(false)
+ }
  return err
  }
 }