Subscribe correctly
This commit is contained in:
parent
c2d3f79a08
commit
c4e696f359
@ -42,7 +42,6 @@ public class CountMultiSearcher implements MultiSearcher {
|
|||||||
return queryParamsMono.flatMap(queryParams2 -> LLUtils.usingSendResource(indexSearchersMono, indexSearchers -> {
|
return queryParamsMono.flatMap(queryParams2 -> LLUtils.usingSendResource(indexSearchersMono, indexSearchers -> {
|
||||||
var localQueryParams = getLocalQueryParams(queryParams2);
|
var localQueryParams = getLocalQueryParams(queryParams2);
|
||||||
return Mono.fromRunnable(() -> {
|
return Mono.fromRunnable(() -> {
|
||||||
LLUtils.ensureBlocking();
|
|
||||||
if (queryParams2.isSorted() && queryParams2.limitLong() > 0) {
|
if (queryParams2.isSorted() && queryParams2.limitLong() > 0) {
|
||||||
throw new UnsupportedOperationException(
|
throw new UnsupportedOperationException(
|
||||||
"Sorted queries are not supported by SimpleUnsortedUnscoredLuceneMultiSearcher");
|
"Sorted queries are not supported by SimpleUnsortedUnscoredLuceneMultiSearcher");
|
||||||
|
Loading…
x
Reference in New Issue
Block a user