diff --git a/src/main/java/it/cavallium/dbengine/lucene/collector/ReactiveLeafCollector.java b/src/main/java/it/cavallium/dbengine/lucene/collector/ReactiveLeafCollector.java
index 0e8e65c..6eea953 100644
--- a/src/main/java/it/cavallium/dbengine/lucene/collector/ReactiveLeafCollector.java
+++ b/src/main/java/it/cavallium/dbengine/lucene/collector/ReactiveLeafCollector.java
@@ -35,8 +35,9 @@ public class ReactiveLeafCollector implements LeafCollector {
 					|| currentError == EmitResult.FAIL_ZERO_SUBSCRIBER;
 			if (shouldRetry) {
 				LockSupport.parkNanos(10);
+			} else {
+				currentError.orThrow();
 			}
-			currentError.orThrow();
 
 		} while (shouldRetry);
 	}