Cwikius-Spring/spring-data-elasticsearch
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-data-elasticsearch.git synced 2025-06-01 09:42:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

DATAES-945 - Compilation error on JDK11+.

Browse Source 
Original PR: #533
This commit is contained in:
Peter-Josef Meisch 2020-10-08 07:40:23 +02:00 committed by GitHub
parent 4a25d3463b
commit 49068b4e00
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/springframework/data/elasticsearch/client/reactive/DefaultReactiveElasticsearchClient.java
View File

@ -611,8 +611,11 @@ public class DefaultReactiveElasticsearchClient implements ReactiveElasticsearch
String logId = ClientLogger.newLogId(); String logId = ClientLogger.newLogId();
return Flux.from(execute(webClient -> sendRequest(webClient, logId, request, headers) return Flux
.exchangeToMono(clientResponse -> Mono.from(readResponseBody(logId, request, clientResponse, responseType))))); .from(execute(webClient -> sendRequest(webClient, logId, request, headers).exchangeToMono(clientResponse -> {
Publisher<? extends Resp> publisher = readResponseBody(logId, request, clientResponse, responseType);
return Mono.from(publisher);
})));
} }
private RequestBodySpec sendRequest(WebClient webClient, String logId, Request request, HttpHeaders headers) { private RequestBodySpec sendRequest(WebClient webClient, String logId, Request request, HttpHeaders headers) {