diff --git a/src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java b/src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java index b202a32..35e0d53 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java +++ b/src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java @@ -199,7 +199,7 @@ public class LuceneUtils { if (limit == null || limit == Long.MAX_VALUE) { return offsetedFlux; } else { - return offsetedFlux.limitRequest(limit); + return offsetedFlux.take(limit, true); } }); }