diff --git a/src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java b/src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java
index ff8c9bd..5f86c75 100644
--- a/src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java
+++ b/src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java
@@ -411,8 +411,7 @@ public class LuceneUtils {
 		if (preserveOrder) {
 			return hitsFlux
 					.publishOn(LuceneUtils.luceneScheduler())
-					.mapNotNull(hit -> mapHitBlocking(hit, indexSearchers, keyFieldName))
-					.publishOn(Schedulers.parallel());
+					.mapNotNull(hit -> mapHitBlocking(hit, indexSearchers, keyFieldName));
 		} else {
 			return hitsFlux
 					.buffer(Queues.XS_BUFFER_SIZE, () -> new ArrayList<Object>(Queues.XS_BUFFER_SIZE))
@@ -434,8 +433,7 @@ public class LuceneUtils {
 							return (List<LLKeyScore>) (List<?>) shardHits;
 						}
 					}).subscribeOn(luceneScheduler()))
-					.flatMapIterable(a -> a)
-					.publishOn(Schedulers.parallel());
+					.flatMapIterable(a -> a);
 		}
 	}
 
diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/CountMultiSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/CountMultiSearcher.java
index 3f97902..10eab0c 100644
--- a/src/main/java/it/cavallium/dbengine/lucene/searcher/CountMultiSearcher.java
+++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/CountMultiSearcher.java
@@ -81,7 +81,6 @@ public class CountMultiSearcher implements MultiSearcher {
 					LLUtils.ensureBlocking();
 					return (long) indexSearcher.getIndexSearcher().count(queryParams.query());
 				}).subscribeOn(luceneScheduler()), LLUtils::finalizeResource)
-				.publishOn(Schedulers.parallel())
 				.transform(TimeoutUtil.timeoutMono(queryParams.timeout()))
 				.map(count -> new LuceneSearchResult(TotalHitsCount.of(count, true), Flux.empty()));
 	}
diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/DecimalBucketMultiSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/DecimalBucketMultiSearcher.java
index 6e40b61..3719a63 100644
--- a/src/main/java/it/cavallium/dbengine/lucene/searcher/DecimalBucketMultiSearcher.java
+++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/DecimalBucketMultiSearcher.java
@@ -61,8 +61,7 @@ public class DecimalBucketMultiSearcher {
 						return cmm.search(shard);
 					}).subscribeOn(luceneScheduler()))
 					.collectList()
-					.flatMap(results -> Mono.fromSupplier(() -> cmm.reduce(results)).subscribeOn(luceneScheduler()))
-					.publishOn(Schedulers.parallel());
+					.flatMap(results -> Mono.fromSupplier(() -> cmm.reduce(results)).subscribeOn(luceneScheduler()));
 		});
 	}
 }
diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/LuceneGenerator.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/LuceneGenerator.java
index beed8af..67a7e28 100644
--- a/src/main/java/it/cavallium/dbengine/lucene/searcher/LuceneGenerator.java
+++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/LuceneGenerator.java
@@ -67,8 +67,7 @@ public class LuceneGenerator implements Supplier<ScoreDoc> {
 							return s;
 						}
 				)
-				.subscribeOn(SCHED)
-				.publishOn(Schedulers.parallel());
+				.subscribeOn(SCHED);
 	}
 
 	@Override
diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/SortedScoredFullMultiSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/SortedScoredFullMultiSearcher.java
index d2736a9..ab2965e 100644
--- a/src/main/java/it/cavallium/dbengine/lucene/searcher/SortedScoredFullMultiSearcher.java
+++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/SortedScoredFullMultiSearcher.java
@@ -94,8 +94,7 @@ public class SortedScoredFullMultiSearcher implements MultiSearcher {
 								throw ex;
 							}
 						}).subscribeOn(luceneScheduler()))
-				)
-				.publishOn(Schedulers.parallel());
+				);
 	}
 
 	/**
diff --git a/src/main/java/it/cavallium/dbengine/lucene/searcher/StandardSearcher.java b/src/main/java/it/cavallium/dbengine/lucene/searcher/StandardSearcher.java
index c087b4f..18821d0 100644
--- a/src/main/java/it/cavallium/dbengine/lucene/searcher/StandardSearcher.java
+++ b/src/main/java/it/cavallium/dbengine/lucene/searcher/StandardSearcher.java
@@ -106,8 +106,7 @@ public class StandardSearcher implements MultiSearcher {
 						}
 						return TopDocs.merge(0, queryParams.limitInt(), topDocs);
 					}
-				}).subscribeOn(luceneScheduler())))
-				.publishOn(Schedulers.parallel());
+				}).subscribeOn(luceneScheduler())));
 	}
 
 	/**