diff --git a/client.go b/client.go index 5414fe6..aae2f33 100644 --- a/client.go +++ b/client.go @@ -100,6 +100,11 @@ func (c *Client) SubscribeWithContext(ctx context.Context, stream string, handle } defer resp.Body.Close() + // Successful connection: reset the backoff time. + if c.ReconnectStrategy != nil { + c.ReconnectStrategy.Reset() + } + reader := NewEventStreamReader(resp.Body, c.maxBufferSize) eventChan, errorChan := c.startReadLoop(reader)