Skip to content

Commit 07d4793

Browse files
Prefer static over default
No intention to override witResponsseHandler method so static is more appropriate.
1 parent c286096 commit 07d4793

File tree

2 files changed

+5
-6
lines changed

2 files changed

+5
-6
lines changed

modules/reindex/src/main/java/org/elasticsearch/index/reindex/remote/RemoteScrollableHitSource.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -77,10 +77,10 @@ public RemoteScrollableHitSource(Logger logger, BackoffPolicy backoffPolicy, Thr
7777

7878
@Override
7979
protected void doStart(RejectAwareActionListener<Response> searchListener) {
80-
lookupRemoteVersion(searchListener.withResponseHandler(version -> {
80+
lookupRemoteVersion(RejectAwareActionListener.withResponseHandler(searchListener, version -> {
8181
remoteVersion = version;
8282
execute(RemoteRequestBuilders.initialSearch(searchRequest, query, remoteVersion),
83-
RESPONSE_PARSER, searchListener.withResponseHandler(r -> onStartResponse(searchListener, r)));
83+
RESPONSE_PARSER, RejectAwareActionListener.withResponseHandler(searchListener, r -> onStartResponse(searchListener, r)));
8484
}));
8585
}
8686

server/src/main/java/org/elasticsearch/index/reindex/RejectAwareActionListener.java

+3-4
Original file line numberDiff line numberDiff line change
@@ -31,12 +31,11 @@ public interface RejectAwareActionListener<T> extends ActionListener<T> {
3131
/**
3232
* Return a new listener that delegates failure/reject to original but forwards response to responseHandler
3333
*/
34-
default <X> RejectAwareActionListener<X> withResponseHandler(Consumer<X> responseHandler) {
35-
RejectAwareActionListener<?> outer = this;
34+
static <X> RejectAwareActionListener<X> withResponseHandler(RejectAwareActionListener<?> original, Consumer<X> responseHandler) {
3635
return new RejectAwareActionListener<>() {
3736
@Override
3837
public void onRejection(Exception e) {
39-
outer.onRejection(e);
38+
original.onRejection(e);
4039
}
4140

4241
@Override
@@ -46,7 +45,7 @@ public void onResponse(X t) {
4645

4746
@Override
4847
public void onFailure(Exception e) {
49-
outer.onFailure(e);
48+
original.onFailure(e);
5049
}
5150
};
5251
}

0 commit comments

Comments
 (0)