diff --git a/src/main/java/org/springframework/data/elasticsearch/client/reactive/DefaultReactiveElasticsearchClient.java b/src/main/java/org/springframework/data/elasticsearch/client/reactive/DefaultReactiveElasticsearchClient.java index 984d0785b..e56c1707c 100644 --- a/src/main/java/org/springframework/data/elasticsearch/client/reactive/DefaultReactiveElasticsearchClient.java +++ b/src/main/java/org/springframework/data/elasticsearch/client/reactive/DefaultReactiveElasticsearchClient.java @@ -567,10 +567,6 @@ public class DefaultReactiveElasticsearchClient implements ReactiveElasticsearch .next(); } - /* - * (non-Javadoc) - * @see org.springframework.data.elasticsearch.client.reactive.ReactiveElasticsearchClient#ping(org.springframework.data.elasticsearch.client.reactive.ReactiveElasticsearchClient.ReactiveElasticsearchClientCallback) - */ @Override public Mono execute(ReactiveElasticsearchClientCallback callback) { diff --git a/src/main/java/org/springframework/data/elasticsearch/client/reactive/ReactiveElasticsearchClient.java b/src/main/java/org/springframework/data/elasticsearch/client/reactive/ReactiveElasticsearchClient.java index 9130e9f1e..a85d9283d 100644 --- a/src/main/java/org/springframework/data/elasticsearch/client/reactive/ReactiveElasticsearchClient.java +++ b/src/main/java/org/springframework/data/elasticsearch/client/reactive/ReactiveElasticsearchClient.java @@ -613,6 +613,7 @@ public interface ReactiveElasticsearchClient { * unavailable. * * @param callback the {@link ReactiveElasticsearchClientCallback callback} wielding the actual command to run. + * @param the type emitted by the returned Mono. * @return the {@link Mono} emitting the {@link ClientResponse} once subscribed. */ @SuppressWarnings("JavaDoc") @@ -630,6 +631,7 @@ public interface ReactiveElasticsearchClient { /** * Low level callback interface operating upon {@link WebClient} to send commands towards elasticsearch. * + * @param the type emitted by the returned Mono. * @author Christoph Strobl * @since 3.2 */