From 12e13cfaa30647c08c7118c37c5587f35a2f1942 Mon Sep 17 00:00:00 2001 From: Erick Pintor Date: Thu, 27 Jun 2024 09:46:37 -0300 Subject: [PATCH 1/2] reconnect streams on cluster rollout --- stream.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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) } From 01b68075c0a632eb2f8afbab5c00d8a2f30dfd1e Mon Sep 17 00:00:00 2001 From: Erick Pintor Date: Thu, 27 Jun 2024 09:56:04 -0300 Subject: [PATCH 2/2] increment version to 2.0.1 --- version | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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