Cwikius-Spring/spring-data-elasticsearch
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-data-elasticsearch.git synced 2025-06-24 04:52:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

DATAES-611 - Adapt to API changes in Spring Webflux.

Browse Source 
Original pull request: #295.
This commit is contained in:
P.J.Meisch 2019-07-15 22:09:15 +02:00 committed by Mark Paluch
parent cf7fc61f7b
commit ccfade12b0
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/org/springframework/data/elasticsearch/client/reactive/RawActionResponse.java
View File

@ -30,11 +30,13 @@ import org.springframework.util.MultiValueMap;
import org.springframework.web.reactive.function.BodyExtractor; import org.springframework.web.reactive.function.BodyExtractor;
import org.springframework.web.reactive.function.client.ClientResponse; import org.springframework.web.reactive.function.client.ClientResponse;
import org.springframework.web.reactive.function.client.ExchangeStrategies; import org.springframework.web.reactive.function.client.ExchangeStrategies;
import org.springframework.web.reactive.function.client.WebClientResponseException;
/** /**
* Extension to {@link ActionResponse} that also implements {@link ClientResponse}. * Extension to {@link ActionResponse} that also implements {@link ClientResponse}.
* *
* @author Christoph Strobl * @author Christoph Strobl
* @author Peter-Josef Meisch
* @since 3.2 * @since 3.2
*/ */
class RawActionResponse extends ActionResponse implements ClientResponse { class RawActionResponse extends ActionResponse implements ClientResponse {
@ -174,4 +176,14 @@ class RawActionResponse extends ActionResponse implements ClientResponse {
public <T> Mono<ResponseEntity<List<T>>> toEntityList(ParameterizedTypeReference<T> typeReference) { public <T> Mono<ResponseEntity<List<T>>> toEntityList(ParameterizedTypeReference<T> typeReference) {
return delegate.toEntityList(typeReference); return delegate.toEntityList(typeReference);
} }
/*
* (non-Javadoc)
* @see org.springframework.web.reactive.function.client.ClientResponse#createException()
*/
@Override
public Mono<WebClientResponseException> createException() {
return delegate.createException();
}
} }