[java] feat: Add native Java 11 HTTP client methods to HttpClient interface

java/src/org/openqa/selenium/grid/web/RoutableHttpClientFactory.java

@@ -75,6 +75,21 @@ public HttpResponse execute(HttpRequest request) throws UncheckedIOException {
         public WebSocket openSocket(HttpRequest request, WebSocket.Listener listener) {
           throw new UnsupportedOperationException("openSocket");
         }
+
+        @Override
+        public <T>
+            java.util.concurrent.CompletableFuture<java.net.http.HttpResponse<T>> sendAsyncNative(
+                java.net.http.HttpRequest request,
+                java.net.http.HttpResponse.BodyHandler<T> handler) {
+          throw new UnsupportedOperationException("sendAsyncNative is not supported");
+        }
+
+        @Override
+        public <T> java.net.http.HttpResponse<T> sendNative(
+            java.net.http.HttpRequest request, java.net.http.HttpResponse.BodyHandler<T> handler)
+            throws java.io.IOException, InterruptedException {
+          throw new UnsupportedOperationException("sendNative is not supported");
+        }
       };
     }
 

java/src/org/openqa/selenium/remote/RemoteWebDriverBuilder.java

@@ -297,6 +297,23 @@ public WebSocket openSocket(HttpRequest request, WebSocket.Listener listener) {
               public HttpResponse execute(HttpRequest req) throws UncheckedIOException {
                 return handler.execute(req);
               }
+
+              @Override
+              public <T>
+                  java.util.concurrent.CompletableFuture<java.net.http.HttpResponse<T>>
+                      sendAsyncNative(
+                          java.net.http.HttpRequest request,
+                          java.net.http.HttpResponse.BodyHandler<T> handler) {
+                throw new UnsupportedOperationException("sendAsyncNative is not supported");
+              }
+
+              @Override
+              public <T> java.net.http.HttpResponse<T> sendNative(
+                  java.net.http.HttpRequest request,
+                  java.net.http.HttpResponse.BodyHandler<T> handler)
+                  throws java.io.IOException, InterruptedException {
+                throw new UnsupportedOperationException("sendNative is not supported");
+              }
             };
           }
         };

java/src/org/openqa/selenium/remote/http/HttpClient.java

@@ -39,6 +39,31 @@ default CompletableFuture<HttpResponse> executeAsync(HttpRequest req) {
 
   default void close() {}
 
+  /**
+   * Sends an HTTP request using java.net.http.HttpClient and allows specifying the BodyHandler.
+   *
+   * @param <T> the response body type
+   * @param request the HTTP request to send
+   * @param handler the BodyHandler that determines how to handle the response body
+   * @return a CompletableFuture containing the HTTP response
+   */
+  <T> CompletableFuture<java.net.http.HttpResponse<T>> sendAsyncNative(
+      java.net.http.HttpRequest request, java.net.http.HttpResponse.BodyHandler<T> handler);
+
+  /**
+   * Sends an HTTP request using java.net.http.HttpClient and allows specifying the BodyHandler.
+   *
+   * @param <T> the response body type
+   * @param request the HTTP request to send
+   * @param handler the BodyHandler that determines how to handle the response body
+   * @return the HTTP response
+   * @throws java.io.IOException if an I/O error occurs
+   * @throws InterruptedException if the operation is interrupted
+   */
+  <T> java.net.http.HttpResponse<T> sendNative(
+      java.net.http.HttpRequest request, java.net.http.HttpResponse.BodyHandler<T> handler)
+      throws java.io.IOException, InterruptedException;
+
   interface Factory {
 
     /**

java/src/org/openqa/selenium/remote/http/jdk/JdkHttpClient.java

@@ -509,6 +509,19 @@ private HttpResponse execute0(HttpRequest req) throws UncheckedIOException {
     }
   }
 
+  @Override
+  public <T> CompletableFuture<java.net.http.HttpResponse<T>> sendAsyncNative(
+      java.net.http.HttpRequest request, java.net.http.HttpResponse.BodyHandler<T> handler) {
+    return client.sendAsync(request, handler);
+  }
+
+  @Override
+  public <T> java.net.http.HttpResponse<T> sendNative(
+      java.net.http.HttpRequest request, java.net.http.HttpResponse.BodyHandler<T> handler)
+      throws IOException, InterruptedException {
+    return client.send(request, handler);
+  }
+
   @Override
   public void close() {
     if (this.client == null) {

java/src/org/openqa/selenium/remote/tracing/TracedHttpClient.java

@@ -57,6 +57,19 @@ public HttpResponse execute(HttpRequest req) {
     }
   }
 
+  @Override
+  public <T> java.util.concurrent.CompletableFuture<java.net.http.HttpResponse<T>> sendAsyncNative(
+      java.net.http.HttpRequest request, java.net.http.HttpResponse.BodyHandler<T> handler) {
+    return delegate.sendAsyncNative(request, handler);
+  }
+
+  @Override
+  public <T> java.net.http.HttpResponse<T> sendNative(
+      java.net.http.HttpRequest request, java.net.http.HttpResponse.BodyHandler<T> handler)
+      throws java.io.IOException, InterruptedException {
+    return delegate.sendNative(request, handler);
+  }
+
   @Override
   public void close() {
     delegate.close();

java/test/org/openqa/selenium/grid/testing/PassthroughHttpClient.java

@@ -48,6 +48,19 @@ public WebSocket openSocket(HttpRequest request, WebSocket.Listener listener) {
     throw new UnsupportedOperationException("openSocket");
   }
 
+  @Override
+  public <T> java.util.concurrent.CompletableFuture<java.net.http.HttpResponse<T>> sendAsyncNative(
+      java.net.http.HttpRequest request, java.net.http.HttpResponse.BodyHandler<T> handler) {
+    throw new UnsupportedOperationException("sendAsyncNative");
+  }
+
+  @Override
+  public <T> java.net.http.HttpResponse<T> sendNative(
+      java.net.http.HttpRequest request, java.net.http.HttpResponse.BodyHandler<T> handler)
+      throws java.io.IOException, InterruptedException {
+    throw new UnsupportedOperationException("sendNative");
+  }
+
   public static class Factory implements HttpClient.Factory {
 
     private final Routable handler;

java/test/org/openqa/selenium/remote/ProtocolHandshakeTest.java

@@ -194,5 +194,19 @@ String getRequestPayload() {
     public WebSocket openSocket(HttpRequest request, WebSocket.Listener listener) {
       throw new UnsupportedOperationException("openSocket");
     }
+
+    @Override
+    public <T>
+        java.util.concurrent.CompletableFuture<java.net.http.HttpResponse<T>> sendAsyncNative(
+            java.net.http.HttpRequest request, java.net.http.HttpResponse.BodyHandler<T> handler) {
+      throw new UnsupportedOperationException("sendAsyncNative");
+    }
+
+    @Override
+    public <T> java.net.http.HttpResponse<T> sendNative(
+        java.net.http.HttpRequest request, java.net.http.HttpResponse.BodyHandler<T> handler)
+        throws java.io.IOException, InterruptedException {
+      throw new UnsupportedOperationException("sendNative");
+    }
   }
 }