Skip to content

Commit 6fda776

Browse files
committed
using wrap rather than both delegateFailure and delegateResponse
1 parent 39cf10e commit 6fda776

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

modules/data-streams/src/main/java/org/elasticsearch/datastreams/action/TransportUpdateDataStreamSettingsAction.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -314,11 +314,7 @@ private void updateSettingsOnSingleIndex(
314314
UpdateSettingsClusterStateUpdateRequest.OnStaticSetting.REOPEN_INDICES,
315315
index
316316
),
317-
listener.delegateResponse(
318-
(listener1, e) -> listener1.onResponse(
319-
new UpdateDataStreamSettingsAction.DataStreamSettingsResponse.IndexSettingError(index.getName(), e.getMessage())
320-
)
321-
).delegateFailure((listener1, response) -> {
317+
ActionListener.wrap(response -> {
322318
UpdateDataStreamSettingsAction.DataStreamSettingsResponse.IndexSettingError error;
323319
if (response.isAcknowledged() == false) {
324320
error = new UpdateDataStreamSettingsAction.DataStreamSettingsResponse.IndexSettingError(
@@ -328,8 +324,12 @@ private void updateSettingsOnSingleIndex(
328324
} else {
329325
error = null;
330326
}
331-
listener1.onResponse(error);
332-
})
327+
listener.onResponse(error);
328+
},
329+
e -> listener.onResponse(
330+
new UpdateDataStreamSettingsAction.DataStreamSettingsResponse.IndexSettingError(index.getName(), e.getMessage())
331+
)
332+
)
333333
);
334334
}
335335
}

0 commit comments

Comments
 (0)