Skip to content

Commit bf8876c

Browse files
committed
improved readability
1 parent 03e795b commit bf8876c

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardFollowTasksExecutor.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -385,9 +385,11 @@ static Client wrapClient(Client client, ShardFollowTask shardFollowTask) {
385385
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
386386
return new FilterClient(client) {
387387
@Override
388-
protected <Request extends ActionRequest, Response extends ActionResponse, RequestBuilder extends
389-
ActionRequestBuilder<Request, Response, RequestBuilder>> void doExecute(Action<Request, Response,
390-
RequestBuilder> action, Request request, ActionListener<Response> listener) {
388+
protected <
389+
Request extends ActionRequest,
390+
Response extends ActionResponse,
391+
RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>>
392+
void doExecute(Action<Request, Response, RequestBuilder> action, Request request, ActionListener<Response> listener) {
391393
final Supplier<ThreadContext.StoredContext> supplier = threadContext.newRestorableContext(false);
392394
try (ThreadContext.StoredContext ignore = stashWithHeaders(threadContext, filteredHeaders)) {
393395
super.doExecute(action, request, new ContextPreservingActionListener<>(supplier, listener));

0 commit comments

Comments
 (0)