Update reactor
This commit is contained in:
parent
f3a7dcdcf8
commit
6ccff7646b
@ -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);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user