Fix deadlock in GoChannel (#318)

ThreeDotsLabs · Jan 21, 2023 · 6adfe4e · 6adfe4e
1 parent f6254b4
commit 6adfe4e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pubsub/gochannel/pubsub.go b/pubsub/gochannel/pubsub.go
@@ -174,6 +174,7 @@ func (g *GoChannel) Subscribe(ctx context.Context, topic string) (<-chan *messag
 	g.closedLock.Lock()
 
 	if g.closed {
+		g.closedLock.Unlock()
 		return nil, errors.New("Pub/Sub closed")
 	}