diff --git a/rpc/eventstream/eventstream.go b/rpc/eventstream/eventstream.go
index e7eac41c..231f91a6 100644
--- a/rpc/eventstream/eventstream.go
+++ b/rpc/eventstream/eventstream.go
@@ -204,6 +204,9 @@ func (stream *Stream) retryRestartStream() {
 			go stream.stream(r)
 			return
 		}
+		if stream.isClosed {
+			return
+		}
 		stream.Errors <- err
 		backoff = 10 * time.Second
 	}