diff --git a/pool.go b/pool.go index a5b5a53..7d4a039 100644 --- a/pool.go +++ b/pool.go @@ -491,7 +491,7 @@ func (pool *SimplePool) subMany( subscribe: 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 { pool.duplicateMiddleware(relay, id) }