diff --git a/src/main/java/org/springframework/data/elasticsearch/client/reactive/RawActionResponse.java b/src/main/java/org/springframework/data/elasticsearch/client/reactive/RawActionResponse.java index 65c8d72fe..02fe7a93b 100644 --- a/src/main/java/org/springframework/data/elasticsearch/client/reactive/RawActionResponse.java +++ b/src/main/java/org/springframework/data/elasticsearch/client/reactive/RawActionResponse.java @@ -30,11 +30,13 @@ import org.springframework.util.MultiValueMap; import org.springframework.web.reactive.function.BodyExtractor; import org.springframework.web.reactive.function.client.ClientResponse; 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}. * * @author Christoph Strobl + * @author Peter-Josef Meisch * @since 3.2 */ class RawActionResponse extends ActionResponse implements ClientResponse { @@ -174,4 +176,14 @@ class RawActionResponse extends ActionResponse implements ClientResponse { public Mono>> toEntityList(ParameterizedTypeReference typeReference) { return delegate.toEntityList(typeReference); } + + /* + * (non-Javadoc) + * @see org.springframework.web.reactive.function.client.ClientResponse#createException() + */ + @Override + public Mono createException() { + return delegate.createException(); + } + }