diff --git a/relay.go b/relay.go
index 0ffe042..5825689 100644
--- a/relay.go
+++ b/relay.go
@@ -449,6 +449,7 @@ func (r *Relay) QueryEvents(ctx context.Context, filter Filter) (chan *Event, er
 			case <-r.Context().Done():
 			}
 			sub.Unsub()
+			return
 		}
 	}()