diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/UnsortedUnscoredContinuousLuceneMultiSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/UnsortedUnscoredContinuousLuceneMultiSearcher.java
index 6342035..a8226d8 100644
--- a/src/main/java/it/cavallium/dbengine/lucene/searcher/UnsortedUnscoredContinuousLuceneMultiSearcher.java
+++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/UnsortedUnscoredContinuousLuceneMultiSearcher.java
@@ -78,11 +78,19 @@ public class UnsortedUnscoredContinuousLuceneMultiSearcher implements LuceneMult
 									throw new UnsupportedOperationException("Called collect in a nonblocking thread");
 								}
 								var scoreDoc = new ScoreDoc(context.docBase + i, 0, shardIndex);
-								synchronized (scoreDocsSink) {
-									while (scoreDocsSink.tryEmitNext(scoreDoc) == EmitResult.FAIL_OVERFLOW) {
+								boolean shouldRetry;
+								do {
+									var currentError = scoreDocsSink.tryEmitNext(scoreDoc);
+									shouldRetry = currentError == EmitResult.FAIL_NON_SERIALIZED
+											|| currentError == EmitResult.FAIL_OVERFLOW
+											|| currentError == EmitResult.FAIL_ZERO_SUBSCRIBER;
+									if (shouldRetry) {
 										LockSupport.parkNanos(10);
 									}
-								}
+									if (!shouldRetry && currentError.isFailure()) {
+										currentError.orThrow();
+									}
+								} while (shouldRetry);
 							}
 
 							@Override