fix a stupid bool.
This commit is contained in:
4
pool.go
4
pool.go
@@ -86,7 +86,7 @@ func (pool *SimplePool) subMany(ctx context.Context, urls []string, filters Filt
|
|||||||
}
|
}
|
||||||
|
|
||||||
for evt := range sub.Events {
|
for evt := range sub.Events {
|
||||||
stop := true
|
stop := false
|
||||||
if unique {
|
if unique {
|
||||||
_, stop = seenAlready.LoadOrStore(evt.ID, true)
|
_, stop = seenAlready.LoadOrStore(evt.ID, true)
|
||||||
}
|
}
|
||||||
@@ -160,7 +160,7 @@ func (pool *SimplePool) subManyEose(ctx context.Context, urls []string, filters
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
stop := true
|
stop := false
|
||||||
if unique {
|
if unique {
|
||||||
_, stop = seenAlready.LoadOrStore(evt.ID, true)
|
_, stop = seenAlready.LoadOrStore(evt.ID, true)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user