diff --git a/opensearch/query.go b/opensearch/query.go
index b30c436..164675b 100644
--- a/opensearch/query.go
+++ b/opensearch/query.go
@@ -155,6 +155,7 @@ func (oss *OpensearchStorage) QueryEvents(ctx context.Context, filter nostr.Filt
 		}
 		if ch != nil {
 			close(ch)
+            ch = nil
 		}
 	}()