fix send on closed channel when closing eventstream

ethpandaops · Aug 25, 2023 · e09ec2d · e09ec2d
1 parent dd2d909
commit e09ec2d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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
 	}