Close subscriber after each use

ipni · Aug 1, 2023 · 7c6a0b5 · 7c6a0b5
1 parent 59492fc
commit 7c6a0b5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/adpub/client.go b/pkg/adpub/client.go
@@ -130,6 +130,8 @@ func (c *client) Distance(ctx context.Context, oldestCid, newestCid cid.Cid) (in
 	if err != nil {
 		return 0, cid.Undef, err
 	}
+	defer sub.Close()
+
 	newestCid, err = sub.Sync(ctx, c.publisher, newestCid, sel)
 	if err != nil {
 		return 0, cid.Undef, err