Skip to content

Commit 37c3409

Browse files
author
elasticsearchmachine
committed
[CI] Auto commit changes from spotless
1 parent f5c1ea0 commit 37c3409

File tree

1 file changed

+8
-14
lines changed

1 file changed

+8
-14
lines changed

server/src/main/java/org/elasticsearch/search/SearchService.java

Lines changed: 8 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -1911,20 +1911,14 @@ private void rewriteAndFetchShardRequest(IndexShard shard, ShardSearchRequest re
19111911
Rewriteable.rewriteAndFetch(
19121912
request.getRewriteable(),
19131913
indicesService.getDataRewriteContext(request::nowInMillis),
1914-
request.readerId() == null
1915-
? listener.delegateFailureAndWrap(
1916-
(l, r) -> shard.ensureShardSearchActive(
1917-
waitedForRefresh -> {
1918-
if (waitedForRefresh) {
1919-
// for to generic in case the listener accesses the engine
1920-
threadPool.generic().execute(ActionRunnable.supply(l, () -> request));
1921-
} else {
1922-
l.onResponse(request);
1923-
}
1924-
}
1925-
)
1926-
)
1927-
: listener.safeMap(r -> request)
1914+
request.readerId() == null ? listener.delegateFailureAndWrap((l, r) -> shard.ensureShardSearchActive(waitedForRefresh -> {
1915+
if (waitedForRefresh) {
1916+
// for to generic in case the listener accesses the engine
1917+
threadPool.generic().execute(ActionRunnable.supply(l, () -> request));
1918+
} else {
1919+
l.onResponse(request);
1920+
}
1921+
})) : listener.safeMap(r -> request)
19281922
);
19291923
}
19301924

0 commit comments

Comments
 (0)