-
Notifications
You must be signed in to change notification settings - Fork 678
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add overload to ReactiveSortingRepository accepting a Limit parameter. #2959
Conversation
src/main/java/org/springframework/data/repository/reactive/ReactiveSortingRepository.java
Outdated
Show resolved
Hide resolved
src/test/java/org/springframework/data/repository/reactive/ReactiveSortingRepositoryTest.java
Outdated
Show resolved
Hide resolved
replace `Limit.unlimited()` with `Limit.of(Integer.MAX_VALUE)` Related spring-projects#2923
Thanks for proposing a pull request. Adding |
@mp911de Before I move on from this, I would like to clarify a few points to ensure that I fully understand the project's direction and to contribute effectively in the future:
return findAll(sort)
.handle((t, sink) -> {
if (sink.requestedFromDownstream() > 0) {
sink.next(t);
}
})
.limitRequest(maxLimit);
Your insights will be invaluable for guiding future contributions and ensuring they are in line with the project's goals. Thank you for your time and consideration. |
Related issue: #2923
Motivation
Flux<T> findAll(Sort sort, Limit limit);
findAll(sort, limit)
onReactiveSortingRepository
Modification
findAll(sort, limit)
onReactiveSortingRepository
Result
Limit
parameter. #2923findAll(sort, limit)
onReactiveSortingRepository