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