fix: async contract leak

Author: SoulPancake

src/main/java/dev/openfga/sdk/api/client/ApiExecutor.java

@@ -51,11 +51,8 @@ public ApiExecutor(ApiClient apiClient, Configuration configuration) {
      *
      * @param requestBuilder Request configuration
      * @return CompletableFuture with API response containing string data
-     * @throws FgaInvalidParameterException If configuration is invalid
-     * @throws ApiException If request construction fails
      */
-    public CompletableFuture<ApiResponse<String>> send(ApiExecutorRequestBuilder requestBuilder)
-            throws FgaInvalidParameterException, ApiException {
+    public CompletableFuture<ApiResponse<String>> send(ApiExecutorRequestBuilder requestBuilder) {
         return send(requestBuilder, String.class);
     }
 
@@ -66,11 +63,8 @@ public CompletableFuture<ApiResponse<String>> send(ApiExecutorRequestBuilder req
      * @param requestBuilder Request configuration
      * @param responseType Class to deserialize response into
      * @return CompletableFuture with API response containing typed data
-     * @throws FgaInvalidParameterException If configuration is invalid
-     * @throws ApiException If request construction fails
      */
-    public <T> CompletableFuture<ApiResponse<T>> send(ApiExecutorRequestBuilder requestBuilder, Class<T> responseType)
-            throws FgaInvalidParameterException, ApiException {
+    public <T> CompletableFuture<ApiResponse<T>> send(ApiExecutorRequestBuilder requestBuilder, Class<T> responseType) {
         if (requestBuilder == null) {
             throw new IllegalArgumentException("Request builder cannot be null");
         }
@@ -87,7 +81,7 @@ public <T> CompletableFuture<ApiResponse<T>> send(ApiExecutorRequestBuilder requ
             return new HttpRequestAttempt<>(httpRequest, methodName, responseType, apiClient, configuration)
                     .attemptHttpRequest();
 
-        } catch (IOException e) {
+        } catch (FgaInvalidParameterException | IOException | IllegalArgumentException | ApiException e) {
             return CompletableFuture.failedFuture(new ApiException(e));
         }
     }

src/main/java/dev/openfga/sdk/api/client/StreamingApiExecutor.java

@@ -91,9 +91,8 @@ private static <V> V requireNonNull(V value, String message) {
      *                       structures or call {@link java.util.concurrent.CompletableFuture#get()
      *                       get()} before accessing results from the calling thread.
      * @return CompletableFuture&lt;Void&gt; that completes when the stream is exhausted,
-     *         or fails exceptionally. All errors — including null arguments, configuration
-     *         validation failures, and HTTP errors — are routed through the future;
-     *         callers only need {@code .exceptionally()} handling.
+     *         or fails exceptionally for configuration or HTTP errors.
+     * @throws IllegalArgumentException if {@code requestBuilder} or {@code consumer} is null
      */
     public CompletableFuture<Void> stream(ApiExecutorRequestBuilder requestBuilder, Consumer<T> consumer) {
         return stream(requestBuilder, consumer, null);
@@ -110,21 +109,21 @@ public CompletableFuture<Void> stream(ApiExecutorRequestBuilder requestBuilder,
      *                       {@code CompletableFuture} always reflects the error regardless of
      *                       whether an {@code errorConsumer} is present.
      * @return CompletableFuture&lt;Void&gt; that completes when the stream is exhausted,
-     *         or fails exceptionally. All errors — including null arguments, configuration
-     *         validation failures, and HTTP errors — are routed through the future;
-     *         callers only need {@code .exceptionally()} handling.
+     *         or fails exceptionally for configuration or HTTP errors.
+     * @throws IllegalArgumentException if {@code requestBuilder} or {@code consumer} is null
      */
     public CompletableFuture<Void> stream(
             ApiExecutorRequestBuilder requestBuilder,
             Consumer<T> consumer,
             @Nullable Consumer<Throwable> errorConsumer) {
+        if (requestBuilder == null) {
+            throw new IllegalArgumentException("Request builder cannot be null");
+        }
+        if (consumer == null) {
+            throw new IllegalArgumentException("Consumer cannot be null");
+        }
+
         try {
-            if (requestBuilder == null) {
-                throw new IllegalArgumentException("Request builder cannot be null");
-            }
-            if (consumer == null) {
-                throw new IllegalArgumentException("Consumer cannot be null");
-            }
             configuration.assertValid();
             return processStreamingResponse(
                     requestBuilder.buildHttpRequest(configuration, apiClient), consumer, errorConsumer);

src/test/java/dev/openfga/sdk/api/client/StreamingApiExecutorTest.java

@@ -323,24 +323,18 @@ public void streamingApiExecutor_typeReferenceOverload_works() throws Exception
     }
 
     @Test
-    public void stream_throwsForNullRequestBuilder() throws Exception {
+    public void stream_throwsForNullRequestBuilder() {
         StreamingApiExecutor<StreamedListObjectsResponse> executor =
                 fga.streamingApiExecutor(StreamedListObjectsResponse.class);
-        CompletableFuture<Void> future = executor.stream(null, obj -> {});
-        ExecutionException ex = assertThrows(ExecutionException.class, future::get);
-        assertInstanceOf(ApiException.class, ex.getCause());
-        assertInstanceOf(IllegalArgumentException.class, ex.getCause().getCause());
+        assertThrows(IllegalArgumentException.class, () -> executor.stream(null, obj -> {}));
     }
 
     @Test
-    public void stream_throwsForNullConsumer() throws Exception {
+    public void stream_throwsForNullConsumer() {
         StreamingApiExecutor<StreamedListObjectsResponse> executor =
                 fga.streamingApiExecutor(StreamedListObjectsResponse.class);
         ApiExecutorRequestBuilder request = buildStreamedListObjectsRequest();
-        CompletableFuture<Void> future = executor.stream(request, null);
-        ExecutionException ex = assertThrows(ExecutionException.class, future::get);
-        assertInstanceOf(ApiException.class, ex.getCause());
-        assertInstanceOf(IllegalArgumentException.class, ex.getCause().getCause());
+        assertThrows(IllegalArgumentException.class, () -> executor.stream(request, null));
     }
 
     @Test