lmdb: hotfix for leaked goroutine.

fiatjaf · Oct 6, 2024 · 1f67814 · 1f67814
1 parent 14c3818
commit 1f67814
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/lmdb/query.go b/lmdb/query.go
@@ -156,9 +156,13 @@ func (b *LMDBBackend) QueryEvents(ctx context.Context, filter nostr.Filter) (cha
 		// first pass
 		emitQueue := make(priorityQueue, 0, len(queries))
 		for _, q := range queries {
-			evt, ok := <-q.results
-			if ok {
-				emitQueue = append(emitQueue, &queryEvent{Event: evt, query: q.i})
+			select {
+			case evt, ok := <-q.results:
+				if ok {
+					emitQueue = append(emitQueue, &queryEvent{Event: evt, query: q.i})
+				}
+			case <-ctx.Done():
+				return
 			}
 		}