Comments

Author: DaveCTurner

server/src/main/java/org/elasticsearch/cluster/action/shard/ShardStateAction.java

@@ -538,6 +538,10 @@ public record FailedShardUpdateTask(FailedShardEntry entry, ActionListener<Trans
             ClusterStateTaskListener,
             ActionListener<ClusterState> {
 
+        /**
+         * This task is re-used as its own publication listener, so this method is called when it has been executed and the resulting
+         * publication completed successfully.
+         */
         @Override
         public void onResponse(ClusterState clusterState) {
             listener.onResponse(TransportResponse.Empty.INSTANCE);
@@ -852,6 +856,10 @@ public StartedShardEntry getEntry() {
             return entry;
         }
 
+        /**
+         * This task is re-used as its own publication listener, so this method is called when it has been executed and the resulting
+         * publication completed successfully.
+         */
         @Override
         public void onResponse(ClusterState clusterState) {
             listener.onResponse(TransportResponse.Empty.INSTANCE);