diff --git a/adding.go b/adding.go index 30ef757..3f9e3f2 100644 --- a/adding.go +++ b/adding.go @@ -38,9 +38,11 @@ func (rl *Relay) AddEvent(ctx context.Context, evt *nostr.Event) error { if err != nil { continue } - if previous := <-ch; previous != nil && isOlder(previous, evt) { - for _, del := range rl.DeleteEvent { - del(ctx, previous) + for previous := range ch { + if isOlder(previous, evt) { + for _, del := range rl.DeleteEvent { + del(ctx, previous) + } } } } @@ -53,9 +55,11 @@ func (rl *Relay) AddEvent(ctx context.Context, evt *nostr.Event) error { if err != nil { continue } - if previous := <-ch; previous != nil && isOlder(previous, evt) { - for _, del := range rl.DeleteEvent { - del(ctx, previous) + for previous := range ch { + if isOlder(previous, evt) { + for _, del := range rl.DeleteEvent { + del(ctx, previous) + } } } }