Reset the backoff time on successful connection

r3labs · Feb 14, 2023 · 4bcb6c8 · 4bcb6c8
1 parent a3b4b97
commit 4bcb6c8
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/client.go b/client.go
@@ -96,6 +96,9 @@ func (c *Client) SubscribeWithContext(ctx context.Context, stream string, handle
 		}
 		defer resp.Body.Close()
 
+		// Successful connection: reset the backoff time.
+		c.ReconnectStrategy.Reset()
+
 		reader := NewEventStreamReader(resp.Body, c.maxBufferSize)
 		eventChan, errorChan := c.startReadLoop(reader)