diff --git a/src/main/java/it/cavallium/dbengine/client/LuceneIndexImpl.java b/src/main/java/it/cavallium/dbengine/client/LuceneIndexImpl.java index b3927b5..85efadb 100644 --- a/src/main/java/it/cavallium/dbengine/client/LuceneIndexImpl.java +++ b/src/main/java/it/cavallium/dbengine/client/LuceneIndexImpl.java @@ -184,6 +184,11 @@ public class LuceneIndexImpl implements LuceneIndex { } private static Mono mergeResults(List shards) { + if (shards.size() == 0) { + return Mono.empty(); + } else if (shards.size() == 1) { + return Mono.just(shards.get(0)); + } return Mono.fromCallable(() -> { TotalHitsCount count = null; ObjectArrayList> results = new ObjectArrayList<>(shards.size());