Subscribe on the same thread

2021-09-08 21:35:04 +02:00 · 2021-09-08 21:35:04 +02:00 · e12e240487
commit e12e240487
parent 09c7e4f730
1 changed files with 1 additions and 0 deletions
--- a/src/main/java/it/cavallium/dbengine/lucene/searcher/ScoredSimpleLuceneShardSearcher.java
+++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/ScoredSimpleLuceneShardSearcher.java
@ -149,6 +149,7 @@ class ScoredSimpleLuceneShardSearcher implements LuceneShardSearcher {
 															})
 															.single()
 															.takeUntilOther(cancelEvent.asMono())
+															.subscribeOn(Schedulers.immediate())
 															.block();
 													if (!emitter.isCancelled()) {
 														Objects.requireNonNull(pageTopDocs);