close pubsub

christianselig · Apr 1, 2023 · d8ddfc7 · d8ddfc7
1 parent cd0645a
commit d8ddfc7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/distributedlock/distributed_lock.go b/internal/distributedlock/distributed_lock.go
@@ -71,6 +71,7 @@ func (d *DistributedLock) WaitAcquireLock(ctx context.Context, key string, timeo
 
 	ch := fmt.Sprintf(lockTopicFormat, key)
 	pubsub := d.client.Subscribe(ctx, ch)
+	defer func() { _ = pubsub.Close() }()
 
 	select {
 	case <-time.After(timeout):