From 9141252b224ef57ea37db730a5b22d56c34706ff Mon Sep 17 00:00:00 2001 From: sincolb Date: Fri, 7 Mar 2025 15:09:31 +0800 Subject: [PATCH] update UnSubscribe --- event_hub.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/event_hub.go b/event_hub.go index 3eb9302..11a9f88 100644 --- a/event_hub.go +++ b/event_hub.go @@ -119,6 +119,10 @@ func (hub *EventHub) SubscribesWithContext(ctx context.Context, timeout time.Dur } func (hub *EventHub) UnSubscribe(key any) { + if hub.Closed() { + return + } + if cond, ok := key.(*sync.Cond); ok { cond.L.Lock() cond.Signal()