From 18cee7421a94ec33acafaff1d0725e1cde2b80ba Mon Sep 17 00:00:00 2001 From: fiatjaf Date: Sat, 16 Sep 2023 07:51:22 -0300 Subject: [PATCH] fix xsync counter initialization. --- pool.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pool.go b/pool.go index 8f99f61..b550b55 100644 --- a/pool.go +++ b/pool.go @@ -56,7 +56,7 @@ func (pool *SimplePool) SubMany(ctx context.Context, urls []string, filters Filt uniqueEvents := make(chan *Event) seenAlready := xsync.NewMapOf[bool]() - pending := xsync.Counter{} + pending := xsync.NewCounter() initial := len(urls) pending.Add(int64(initial)) for _, url := range urls {