mirror of
https://github.com/spring-projects/spring-data-elasticsearch.git
synced 2025-06-01 09:42:11 +00:00
DATAES-921 - Polishing.
This commit is contained in:
parent
980aff30ae
commit
f1dc7fc95c
@ -567,10 +567,6 @@ public class DefaultReactiveElasticsearchClient implements ReactiveElasticsearch
|
|||||||
.next();
|
.next();
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
|
||||||
* (non-Javadoc)
|
|
||||||
* @see org.springframework.data.elasticsearch.client.reactive.ReactiveElasticsearchClient#ping(org.springframework.data.elasticsearch.client.reactive.ReactiveElasticsearchClient.ReactiveElasticsearchClientCallback)
|
|
||||||
*/
|
|
||||||
@Override
|
@Override
|
||||||
public <T> Mono<T> execute(ReactiveElasticsearchClientCallback<T> callback) {
|
public <T> Mono<T> execute(ReactiveElasticsearchClientCallback<T> callback) {
|
||||||
|
|
||||||
|
@ -613,6 +613,7 @@ public interface ReactiveElasticsearchClient {
|
|||||||
* unavailable.
|
* unavailable.
|
||||||
*
|
*
|
||||||
* @param callback the {@link ReactiveElasticsearchClientCallback callback} wielding the actual command to run.
|
* @param callback the {@link ReactiveElasticsearchClientCallback callback} wielding the actual command to run.
|
||||||
|
* @param <T> the type emitted by the returned Mono.
|
||||||
* @return the {@link Mono} emitting the {@link ClientResponse} once subscribed.
|
* @return the {@link Mono} emitting the {@link ClientResponse} once subscribed.
|
||||||
*/
|
*/
|
||||||
@SuppressWarnings("JavaDoc")
|
@SuppressWarnings("JavaDoc")
|
||||||
@ -630,6 +631,7 @@ public interface ReactiveElasticsearchClient {
|
|||||||
/**
|
/**
|
||||||
* Low level callback interface operating upon {@link WebClient} to send commands towards elasticsearch.
|
* Low level callback interface operating upon {@link WebClient} to send commands towards elasticsearch.
|
||||||
*
|
*
|
||||||
|
* @param <T> the type emitted by the returned Mono.
|
||||||
* @author Christoph Strobl
|
* @author Christoph Strobl
|
||||||
* @since 3.2
|
* @since 3.2
|
||||||
*/
|
*/
|
||||||
|
Loading…
x
Reference in New Issue
Block a user