From e09ec2d09107acb3e9da5acc4ae6fcdad04f0f69 Mon Sep 17 00:00:00 2001 From: pk910 Date: Fri, 25 Aug 2023 23:39:26 +0200 Subject: [PATCH] fix send on closed channel when closing eventstream --- rpc/eventstream/eventstream.go | 3 +++ 1 file changed, 3 insertions(+) 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 }