Throw error only when needed

This commit is contained in:
Andrea Cavalli 2021-09-26 15:10:42 +02:00
parent 5d7b403e55
commit 74f2cce604

View File

@ -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);
}