diff --git a/search/collectors/collector_heap.go b/search/collectors/collector_heap.go
index 4a02e4d0..be58a4d4 100644
--- a/search/collectors/collector_heap.go
+++ b/search/collectors/collector_heap.go
@@ -63,7 +63,10 @@ func (hc *HeapCollector) Collect(ctx context.Context, searcher search.Searcher)
 			default:
 			}
 		}
-		hc.collectSingle(next)
+		err = hc.collectSingle(next)
+		if err != nil {
+			break
+		}
 		if hc.facetsBuilder != nil {
 			err = hc.facetsBuilder.Update(next)
 			if err != nil {