notify the listener if the request gets cancelled

client/rest/src/main/java/org/elasticsearch/client/RestClient.java

@@ -58,6 +58,7 @@ import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 
@@ -346,6 +347,7 @@ public final class RestClient implements Closeable {
 
             @Override
             public void cancelled() {
+                listener.onDefinitiveFailure(new ExecutionException("request was cancelled", null));
             }
         });
     }