From 329511c38b0d278962b48e60ba7f1a31aa6d2cd7 Mon Sep 17 00:00:00 2001 From: Erick Pintor Date: Thu, 27 Jun 2024 09:58:34 -0300 Subject: [PATCH] Reconnect streams on cluster rollout (#163) --- stream.go | 2 +- version | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/stream.go b/stream.go index a081bcf..8346d2c 100644 --- a/stream.go +++ b/stream.go @@ -155,7 +155,7 @@ func (es *Events) Next(event *Event) (err error) { // presume that if the service is unavailable, the reconnect call will // fail. Automatic retries and backoff mechanisms are impleneted at the // Client level. - if _, ok := err.(net.Error); ok || err == io.ErrUnexpectedEOF { + if _, ok := err.(net.Error); ok || err == io.EOF || err == io.ErrUnexpectedEOF { if err = es.reconnect(); err == nil { err = es.Next(event) } diff --git a/version b/version index 10bf840..e9307ca 100644 --- a/version +++ b/version @@ -1 +1 @@ -2.0.1 \ No newline at end of file +2.0.2