mirror of
https://github.com/nbd-wtf/go-nostr.git
synced 2025-12-08 20:03:32 +01:00
fix check duplicate for pool subMany
This commit is contained in:
2
pool.go
2
pool.go
@@ -491,7 +491,7 @@ func (pool *SimplePool) subMany(
|
|||||||
|
|
||||||
subscribe:
|
subscribe:
|
||||||
sub, err = relay.Subscribe(ctx, filters, append(opts, WithCheckDuplicate(func(id, relay string) bool {
|
sub, err = relay.Subscribe(ctx, filters, append(opts, WithCheckDuplicate(func(id, relay string) bool {
|
||||||
_, exists := seenAlready.Load(id)
|
_, exists := seenAlready.LoadAndStore(id, Timestamp(time.Now().Unix()))
|
||||||
if exists && pool.duplicateMiddleware != nil {
|
if exists && pool.duplicateMiddleware != nil {
|
||||||
pool.duplicateMiddleware(relay, id)
|
pool.duplicateMiddleware(relay, id)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user