fix xsync counter initialization.

2023-09-16 07:51:22 -03:00
parent e55f5492ab
commit 18cee7421a
1 changed files with 1 additions and 1 deletions
--- 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 {