From 85c6191c6a2edc6012936a45dea14884831c1e60 Mon Sep 17 00:00:00 2001
From: SoulPancake <angbpy@gmail.com>
Date: Fri, 5 Dec 2025 16:26:24 +0530
Subject: [PATCH 1/3] chore: make streamedListObjects client layer pvt

---
 examples/streamed-list-objects/README.md      |   3 +
 .../example/StreamedListObjectsExample.java   |   5 +
 .../openfga/sdk/api/client/OpenFgaClient.java |   6 +-
 .../client/OpenFgaClientIntegrationTest.java  |   4 +
 .../api/client/StreamedListObjectsTest.java   | 855 +++++++++---------
 5 files changed, 444 insertions(+), 429 deletions(-)

diff --git a/examples/streamed-list-objects/README.md b/examples/streamed-list-objects/README.md
index 63bbf5d9..5e065909 100644
--- a/examples/streamed-list-objects/README.md
+++ b/examples/streamed-list-objects/README.md
@@ -1,5 +1,8 @@
 # Streamed List Objects Example
 
+> **NOTE:** This example is temporarily disabled as the `streamedListObjects` API is not yet available for public use. It will be enabled in a future release.
+
+<!--
 Demonstrates using `StreamedListObjects` to retrieve objects via the streaming API in the Java SDK.
 
 ## What is StreamedListObjects?
diff --git a/examples/streamed-list-objects/src/main/java/dev/openfga/sdk/example/StreamedListObjectsExample.java b/examples/streamed-list-objects/src/main/java/dev/openfga/sdk/example/StreamedListObjectsExample.java
index 6b07ed62..89e6cb6f 100644
--- a/examples/streamed-list-objects/src/main/java/dev/openfga/sdk/example/StreamedListObjectsExample.java
+++ b/examples/streamed-list-objects/src/main/java/dev/openfga/sdk/example/StreamedListObjectsExample.java
@@ -1,3 +1,7 @@
+// NOTE: This example is temporarily commented out as the streamedListObjects API is not yet available for public use.
+// It will be enabled in a future release.
+
+/*
 package dev.openfga.sdk.example;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -192,3 +196,4 @@ private WriteAuthorizationModelRequest createAuthorizationModel() {
         }
     }
 }
+*/
diff --git a/src/main/java/dev/openfga/sdk/api/client/OpenFgaClient.java b/src/main/java/dev/openfga/sdk/api/client/OpenFgaClient.java
index 4d4df9c3..70ac9df7 100644
--- a/src/main/java/dev/openfga/sdk/api/client/OpenFgaClient.java
+++ b/src/main/java/dev/openfga/sdk/api/client/OpenFgaClient.java
@@ -1131,7 +1131,7 @@ public CompletableFuture<ClientListObjectsResponse> listObjects(
      * @return CompletableFuture<Void> that completes when streaming finishes
      * @throws FgaInvalidParameterException When the Store ID is null, empty, or whitespace, or consumer is null
      */
-    public CompletableFuture<Void> streamedListObjects(
+    private CompletableFuture<Void> streamedListObjects(
             ClientListObjectsRequest request, Consumer<StreamedListObjectsResponse> consumer)
             throws FgaInvalidParameterException {
         if (consumer == null) {
@@ -1171,7 +1171,7 @@ public CompletableFuture<Void> streamedListObjects(
      * @return CompletableFuture<Void> that completes when streaming finishes
      * @throws FgaInvalidParameterException When the Store ID is null, empty, or whitespace, or consumer is null
      */
-    public CompletableFuture<Void> streamedListObjects(
+    private CompletableFuture<Void> streamedListObjects(
             ClientListObjectsRequest request,
             ClientStreamedListObjectsOptions options,
             Consumer<StreamedListObjectsResponse> consumer)
@@ -1211,7 +1211,7 @@ public CompletableFuture<Void> streamedListObjects(
      * @return CompletableFuture<Void> that completes when streaming finishes or exceptionally on error
      * @throws FgaInvalidParameterException When the Store ID is null, empty, or whitespace, or consumer is null
      */
-    public CompletableFuture<Void> streamedListObjects(
+    private CompletableFuture<Void> streamedListObjects(
             ClientListObjectsRequest request,
             ClientStreamedListObjectsOptions options,
             Consumer<StreamedListObjectsResponse> consumer,
diff --git a/src/test-integration/java/dev/openfga/sdk/api/client/OpenFgaClientIntegrationTest.java b/src/test-integration/java/dev/openfga/sdk/api/client/OpenFgaClientIntegrationTest.java
index 1501ba89..5d98d463 100644
--- a/src/test-integration/java/dev/openfga/sdk/api/client/OpenFgaClientIntegrationTest.java
+++ b/src/test-integration/java/dev/openfga/sdk/api/client/OpenFgaClientIntegrationTest.java
@@ -373,6 +373,9 @@ private String writeAuthModel(String storeId) throws Exception {
         return response.getAuthorizationModelId();
     }
 
+    // NOTE: This test is temporarily commented out as the streamedListObjects API is not yet available for public use.
+    // It will be enabled in a future release.
+    /*
     @Test
     public void streamedListObjects() throws Exception {
         // Given - Create a single store for all streaming tests
@@ -464,6 +467,7 @@ public void streamedListObjects() throws Exception {
         assertEquals(20, chainTestObjects.size());
         assertTrue(chainedOperationExecuted.get());
     }
+    */
 
     /** Get the name of the test that invokes this function. Returned in the form: "$class.$fn" */
     private String thisTestName() {
diff --git a/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java b/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java
index a509f68a..a3a4f45c 100644
--- a/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java
+++ b/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java
@@ -1,426 +1,429 @@
-package dev.openfga.sdk.api.client;
-
-import static org.junit.jupiter.api.Assertions.*;
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.Mockito.*;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import dev.openfga.sdk.api.client.model.ClientListObjectsRequest;
-import dev.openfga.sdk.api.client.model.ClientStreamedListObjectsOptions;
-import dev.openfga.sdk.api.configuration.ClientConfiguration;
-import dev.openfga.sdk.api.configuration.Credentials;
-import dev.openfga.sdk.api.model.ConsistencyPreference;
-import dev.openfga.sdk.api.model.StreamedListObjectsResponse;
-import dev.openfga.sdk.constants.FgaConstants;
-import dev.openfga.sdk.errors.FgaInvalidParameterException;
-import java.net.http.HttpClient;
-import java.net.http.HttpHeaders;
-import java.net.http.HttpResponse;
-import java.time.Duration;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.atomic.AtomicInteger;
-import java.util.stream.Stream;
-import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Test;
-
-/** Tests for streaming list objects functionality with CompletableFuture. */
-public class StreamedListObjectsTest {
-    private static final String DEFAULT_STORE_ID = "01YCP46JKYM8FJCQ37NMBYHE5X";
-    private static final String DEFAULT_AUTH_MODEL_ID = "01G5JAVJ41T49E9TT3SKVS7X1J";
-    private static final String DEFAULT_USER = "user:81684243-9356-4421-8fbf-a4f8d36aa31b";
-    private static final String DEFAULT_RELATION = "owner";
-    private static final String DEFAULT_TYPE = "document";
-
-    private OpenFgaClient fga;
-    private ClientConfiguration clientConfiguration;
-    private HttpClient mockHttpClient;
-    private ApiClient mockApiClient;
-
-    @BeforeEach
-    public void beforeEachTest() throws Exception {
-        mockHttpClient = mock(HttpClient.class);
-        var mockHttpClientBuilder = mock(HttpClient.Builder.class);
-        when(mockHttpClientBuilder.executor(any())).thenReturn(mockHttpClientBuilder);
-        when(mockHttpClientBuilder.build()).thenReturn(mockHttpClient);
-
-        clientConfiguration = new ClientConfiguration()
-                .storeId(DEFAULT_STORE_ID)
-                .authorizationModelId(DEFAULT_AUTH_MODEL_ID)
-                .apiUrl(FgaConstants.TEST_API_URL)
-                .credentials(new Credentials())
-                .readTimeout(Duration.ofMillis(250));
-
-        mockApiClient = mock(ApiClient.class);
-        when(mockApiClient.getHttpClient()).thenReturn(mockHttpClient);
-        when(mockApiClient.getObjectMapper()).thenReturn(new ObjectMapper());
-        when(mockApiClient.getHttpClientBuilder()).thenReturn(mockHttpClientBuilder);
-
-        fga = new OpenFgaClient(clientConfiguration, mockApiClient);
-    }
-
-    @Test
-    public void streamedListObjects_success() throws Exception {
-        // Given
-        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
-        String line2 = "{\"result\":{\"object\":\"document:2\"}}";
-        String line3 = "{\"result\":{\"object\":\"document:3\"}}";
-        Stream<String> streamResponse = Stream.of(line1, line2, line3);
-
-        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-                CompletableFuture.completedFuture(mockResponse);
-
-        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-
-        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-        ClientListObjectsRequest request = new ClientListObjectsRequest()
-                .type(DEFAULT_TYPE)
-                .relation(DEFAULT_RELATION)
-                .user(DEFAULT_USER);
-
-        // When
-        CompletableFuture<Void> future = fga.streamedListObjects(request, receivedObjects::add);
-        future.get(); // Wait for completion
-
-        // Then
-        assertEquals(3, receivedObjects.size());
-        assertEquals("document:1", receivedObjects.get(0).getObject());
-        assertEquals("document:2", receivedObjects.get(1).getObject());
-        assertEquals("document:3", receivedObjects.get(2).getObject());
-        verify(mockHttpClient, times(1)).sendAsync(any(), any());
-    }
-
-    @Test
-    public void streamedListObjects_withOptions() throws Exception {
-        // Given
-        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
-        Stream<String> streamResponse = Stream.of(line1);
-
-        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-                CompletableFuture.completedFuture(mockResponse);
-
-        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-
-        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-        ClientListObjectsRequest request = new ClientListObjectsRequest()
-                .type(DEFAULT_TYPE)
-                .relation(DEFAULT_RELATION)
-                .user(DEFAULT_USER);
-
-        ClientStreamedListObjectsOptions options = new ClientStreamedListObjectsOptions()
-                .authorizationModelId("custom-model-id")
-                .consistency(ConsistencyPreference.HIGHER_CONSISTENCY);
-
-        // When
-        CompletableFuture<Void> future = fga.streamedListObjects(request, options, receivedObjects::add);
-        future.get(); // Wait for completion
-
-        // Then
-        assertEquals(1, receivedObjects.size());
-        assertEquals("document:1", receivedObjects.get(0).getObject());
-    }
-
-    @Test
-    public void streamedListObjects_emptyStream() throws Exception {
-        // Given
-        Stream<String> streamResponse = Stream.empty();
-
-        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-                CompletableFuture.completedFuture(mockResponse);
-
-        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-
-        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-        ClientListObjectsRequest request = new ClientListObjectsRequest()
-                .type(DEFAULT_TYPE)
-                .relation(DEFAULT_RELATION)
-                .user(DEFAULT_USER);
-
-        // When
-        CompletableFuture<Void> future = fga.streamedListObjects(request, receivedObjects::add);
-        future.get(); // Wait for completion
-
-        // Then
-        assertEquals(0, receivedObjects.size());
-    }
-
-    @Test
-    public void streamedListObjects_storeIdRequired() {
-        // Given
-        clientConfiguration.storeId(null);
-        ClientListObjectsRequest request = new ClientListObjectsRequest()
-                .type(DEFAULT_TYPE)
-                .relation(DEFAULT_RELATION)
-                .user(DEFAULT_USER);
-
-        // When/Then
-        var exception = assertThrows(FgaInvalidParameterException.class, () -> {
-            fga.streamedListObjects(request, response -> {});
-        });
-
-        assertEquals(
-                "Required parameter storeId was invalid when calling ClientConfiguration.", exception.getMessage());
-    }
-
-    @Test
-    public void streamedListObjects_errorHandling() throws Exception {
-        // Given
-        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
-        String line2 = "{\"error\":{\"message\":\"Something went wrong\"}}";
-        String line3 = "{\"result\":{\"object\":\"document:2\"}}";
-        Stream<String> streamResponse = Stream.of(line1, line2, line3);
-
-        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-                CompletableFuture.completedFuture(mockResponse);
-
-        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-
-        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-        List<Throwable> receivedErrors = new ArrayList<>();
-        ClientListObjectsRequest request = new ClientListObjectsRequest()
-                .type(DEFAULT_TYPE)
-                .relation(DEFAULT_RELATION)
-                .user(DEFAULT_USER);
-
-        // When
-        CompletableFuture<Void> future =
-                fga.streamedListObjects(request, null, receivedObjects::add, receivedErrors::add);
-        future.get(); // Wait for completion
-
-        // Then
-        assertEquals(2, receivedObjects.size());
-        assertEquals("document:1", receivedObjects.get(0).getObject());
-        assertEquals("document:2", receivedObjects.get(1).getObject());
-        assertEquals(1, receivedErrors.size());
-    }
-
-    @Test
-    public void streamedListObjects_errorHandlingWithNullMessage() throws Exception {
-        // Given - error with null message and no code
-        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
-        String line2 = "{\"error\":{}}"; // Empty error object (null message, null code)
-        String line3 = "{\"error\":{\"code\":123}}"; // Error with code but null message
-        Stream<String> streamResponse = Stream.of(line1, line2, line3);
-
-        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-                CompletableFuture.completedFuture(mockResponse);
-
-        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-
-        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-        List<Throwable> receivedErrors = new ArrayList<>();
-        ClientListObjectsRequest request = new ClientListObjectsRequest()
-                .type(DEFAULT_TYPE)
-                .relation(DEFAULT_RELATION)
-                .user(DEFAULT_USER);
-
-        // When
-        CompletableFuture<Void> future =
-                fga.streamedListObjects(request, null, receivedObjects::add, receivedErrors::add);
-        future.get(); // Wait for completion
-
-        // Then - should handle null messages gracefully without NPE
-        assertEquals(1, receivedObjects.size());
-        assertEquals(2, receivedErrors.size());
-
-        // Verify first error has a fallback message
-        assertTrue(receivedErrors.get(0) instanceof dev.openfga.sdk.errors.ApiException);
-        String firstErrorMsg = ((dev.openfga.sdk.errors.ApiException) receivedErrors.get(0)).getMessage();
-        assertTrue(firstErrorMsg.contains("Stream error"));
-        assertTrue(firstErrorMsg.contains("unknown"));
-
-        // Verify second error has code in message
-        assertTrue(receivedErrors.get(1) instanceof dev.openfga.sdk.errors.ApiException);
-        String secondErrorMsg = ((dev.openfga.sdk.errors.ApiException) receivedErrors.get(1)).getMessage();
-        assertTrue(secondErrorMsg.contains("Stream error"));
-        assertTrue(secondErrorMsg.contains("code 123"));
-    }
-
-    @Test
-    public void streamedListObjects_httpError() throws Exception {
-        // Given
-        Stream<String> streamResponse = Stream.empty();
-        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(400, streamResponse);
-        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-                CompletableFuture.completedFuture(mockResponse);
-
-        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-
-        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-        List<Throwable> receivedErrors = new ArrayList<>();
-        ClientListObjectsRequest request = new ClientListObjectsRequest()
-                .type(DEFAULT_TYPE)
-                .relation(DEFAULT_RELATION)
-                .user(DEFAULT_USER);
-
-        // When
-        CompletableFuture<Void> future =
-                fga.streamedListObjects(request, null, receivedObjects::add, receivedErrors::add);
-
-        try {
-            future.get(); // Wait for completion - should fail
-            fail("Expected exception");
-        } catch (Exception e) {
-            // Expected
-        }
-
-        // Then
-        assertEquals(0, receivedObjects.size());
-        assertEquals(1, receivedErrors.size());
-    }
-
-    @Test
-    public void streamedListObjects_consumerInvocationCount() throws Exception {
-        // Given
-        int expectedCount = 100;
-        List<String> lines = new ArrayList<>();
-        for (int i = 0; i < expectedCount; i++) {
-            lines.add(String.format("{\"result\":{\"object\":\"document:%d\"}}", i));
-        }
-        Stream<String> streamResponse = lines.stream();
-
-        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-                CompletableFuture.completedFuture(mockResponse);
-
-        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-
-        AtomicInteger callCount = new AtomicInteger(0);
-        ClientListObjectsRequest request = new ClientListObjectsRequest()
-                .type(DEFAULT_TYPE)
-                .relation(DEFAULT_RELATION)
-                .user(DEFAULT_USER);
-
-        // When
-        CompletableFuture<Void> future = fga.streamedListObjects(request, response -> callCount.incrementAndGet());
-        future.get(); // Wait for completion
-
-        // Then
-        assertEquals(expectedCount, callCount.get());
-    }
-
-    @Test
-    public void streamedListObjects_chainingWithOtherOperations() throws Exception {
-        // Given
-        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
-        Stream<String> streamResponse = Stream.of(line1);
-
-        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-                CompletableFuture.completedFuture(mockResponse);
-
-        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-
-        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-        ClientListObjectsRequest request = new ClientListObjectsRequest()
-                .type(DEFAULT_TYPE)
-                .relation(DEFAULT_RELATION)
-                .user(DEFAULT_USER);
-
-        // When - Chain with other async operations
-        AtomicInteger completionFlag = new AtomicInteger(0);
-        CompletableFuture<Void> future = fga.streamedListObjects(request, receivedObjects::add)
-                .thenRun(() -> completionFlag.set(1))
-                .thenRun(() -> completionFlag.set(2));
-
-        future.get(); // Wait for all chained operations
-
-        // Then
-        assertEquals(1, receivedObjects.size());
-        assertEquals(2, completionFlag.get());
-    }
-
-    @Test
-    public void streamedListObjects_additionalHeadersPassedThrough() throws Exception {
-        // Given
-        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
-        Stream<String> streamResponse = Stream.of(line1);
-
-        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-                CompletableFuture.completedFuture(mockResponse);
-
-        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-
-        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-        ClientListObjectsRequest request = new ClientListObjectsRequest()
-                .type(DEFAULT_TYPE)
-                .relation(DEFAULT_RELATION)
-                .user(DEFAULT_USER);
-
-        // Create options with additional headers
-        Map<String, String> additionalHeaders = Map.of(
-                "X-Custom-Header", "custom-value",
-                "X-Request-ID", "test-request-123");
-
-        ClientStreamedListObjectsOptions options =
-                new ClientStreamedListObjectsOptions().additionalHeaders(additionalHeaders);
-
-        // When
-        CompletableFuture<Void> future = fga.streamedListObjects(request, options, receivedObjects::add);
-        future.get(); // Wait for completion
-
-        // Then
-        assertEquals(1, receivedObjects.size());
-        assertEquals("document:1", receivedObjects.get(0).getObject());
-
-        // Verify that the HTTP client was called (which means headers were applied)
-        verify(mockHttpClient, times(1)).sendAsync(any(), any());
-    }
-
-    @Test
-    public void streamedListObjects_preservesApiExceptionType() throws Exception {
-        // Given - HTTP 400 error should create ApiException
-        Stream<String> streamResponse = Stream.empty();
-        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(400, streamResponse);
-        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-                CompletableFuture.completedFuture(mockResponse);
-
-        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-
-        List<Throwable> receivedErrors = new ArrayList<>();
-        ClientListObjectsRequest request = new ClientListObjectsRequest()
-                .type(DEFAULT_TYPE)
-                .relation(DEFAULT_RELATION)
-                .user(DEFAULT_USER);
-
-        // When
-        CompletableFuture<Void> future = fga.streamedListObjects(request, null, obj -> {}, receivedErrors::add);
-
-        try {
-            future.get();
-            fail("Expected exception");
-        } catch (Exception e) {
-            // Expected to fail
-        }
-
-        // Then - verify the error consumer received the original ApiException, not wrapped
-        assertEquals(1, receivedErrors.size());
-        Throwable error = receivedErrors.get(0);
-        assertTrue(
-                error instanceof dev.openfga.sdk.errors.ApiException,
-                "Expected ApiException but got " + error.getClass().getName());
-        dev.openfga.sdk.errors.ApiException apiException = (dev.openfga.sdk.errors.ApiException) error;
-        assertEquals(400, apiException.getStatusCode());
-    }
-
-    private HttpResponse<Stream<String>> createMockStreamResponse(int statusCode, Stream<String> body) {
-        HttpResponse<Stream<String>> mockResponse = mock(HttpResponse.class);
-        when(mockResponse.statusCode()).thenReturn(statusCode);
-        when(mockResponse.body()).thenReturn(body);
-
-        // Create mock headers
-        HttpHeaders mockHeaders = mock(HttpHeaders.class);
-        when(mockHeaders.map()).thenReturn(Map.of("content-type", List.of("application/json")));
-        when(mockResponse.headers()).thenReturn(mockHeaders);
-
-        return mockResponse;
-    }
-}
+// NOTE: This test is temporarily commented out as the streamedListObjects API is not yet available for public use.
+// It will be enabled in a future release.
+
+//package dev.openfga.sdk.api.client;
+//
+//import static org.junit.jupiter.api.Assertions.*;
+//import static org.mockito.ArgumentMatchers.any;
+//import static org.mockito.Mockito.*;
+//
+//import com.fasterxml.jackson.databind.ObjectMapper;
+//import dev.openfga.sdk.api.client.model.ClientListObjectsRequest;
+//import dev.openfga.sdk.api.client.model.ClientStreamedListObjectsOptions;
+//import dev.openfga.sdk.api.configuration.ClientConfiguration;
+//import dev.openfga.sdk.api.configuration.Credentials;
+//import dev.openfga.sdk.api.model.ConsistencyPreference;
+//import dev.openfga.sdk.api.model.StreamedListObjectsResponse;
+//import dev.openfga.sdk.constants.FgaConstants;
+//import dev.openfga.sdk.errors.FgaInvalidParameterException;
+//import java.net.http.HttpClient;
+//import java.net.http.HttpHeaders;
+//import java.net.http.HttpResponse;
+//import java.time.Duration;
+//import java.util.ArrayList;
+//import java.util.List;
+//import java.util.Map;
+//import java.util.concurrent.CompletableFuture;
+//import java.util.concurrent.atomic.AtomicInteger;
+//import java.util.stream.Stream;
+//import org.junit.jupiter.api.BeforeEach;
+//import org.junit.jupiter.api.Test;
+//
+///** Tests for streaming list objects functionality with CompletableFuture. */
+//public class StreamedListObjectsTest {
+//    private static final String DEFAULT_STORE_ID = "01YCP46JKYM8FJCQ37NMBYHE5X";
+//    private static final String DEFAULT_AUTH_MODEL_ID = "01G5JAVJ41T49E9TT3SKVS7X1J";
+//    private static final String DEFAULT_USER = "user:81684243-9356-4421-8fbf-a4f8d36aa31b";
+//    private static final String DEFAULT_RELATION = "owner";
+//    private static final String DEFAULT_TYPE = "document";
+//
+//    private OpenFgaClient fga;
+//    private ClientConfiguration clientConfiguration;
+//    private HttpClient mockHttpClient;
+//    private ApiClient mockApiClient;
+//
+//    @BeforeEach
+//    public void beforeEachTest() throws Exception {
+//        mockHttpClient = mock(HttpClient.class);
+//        var mockHttpClientBuilder = mock(HttpClient.Builder.class);
+//        when(mockHttpClientBuilder.executor(any())).thenReturn(mockHttpClientBuilder);
+//        when(mockHttpClientBuilder.build()).thenReturn(mockHttpClient);
+//
+//        clientConfiguration = new ClientConfiguration()
+//                .storeId(DEFAULT_STORE_ID)
+//                .authorizationModelId(DEFAULT_AUTH_MODEL_ID)
+//                .apiUrl(FgaConstants.TEST_API_URL)
+//                .credentials(new Credentials())
+//                .readTimeout(Duration.ofMillis(250));
+//
+//        mockApiClient = mock(ApiClient.class);
+//        when(mockApiClient.getHttpClient()).thenReturn(mockHttpClient);
+//        when(mockApiClient.getObjectMapper()).thenReturn(new ObjectMapper());
+//        when(mockApiClient.getHttpClientBuilder()).thenReturn(mockHttpClientBuilder);
+//
+//        fga = new OpenFgaClient(clientConfiguration, mockApiClient);
+//    }
+//
+//    @Test
+//    public void streamedListObjects_success() throws Exception {
+//        // Given
+//        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
+//        String line2 = "{\"result\":{\"object\":\"document:2\"}}";
+//        String line3 = "{\"result\":{\"object\":\"document:3\"}}";
+//        Stream<String> streamResponse = Stream.of(line1, line2, line3);
+//
+//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+//                CompletableFuture.completedFuture(mockResponse);
+//
+//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+//
+//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+//        ClientListObjectsRequest request = new ClientListObjectsRequest()
+//                .type(DEFAULT_TYPE)
+//                .relation(DEFAULT_RELATION)
+//                .user(DEFAULT_USER);
+//
+//        // When
+//        CompletableFuture<Void> future = fga.streamedListObjects(request, receivedObjects::add);
+//        future.get(); // Wait for completion
+//
+//        // Then
+//        assertEquals(3, receivedObjects.size());
+//        assertEquals("document:1", receivedObjects.get(0).getObject());
+//        assertEquals("document:2", receivedObjects.get(1).getObject());
+//        assertEquals("document:3", receivedObjects.get(2).getObject());
+//        verify(mockHttpClient, times(1)).sendAsync(any(), any());
+//    }
+//
+//    @Test
+//    public void streamedListObjects_withOptions() throws Exception {
+//        // Given
+//        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
+//        Stream<String> streamResponse = Stream.of(line1);
+//
+//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+//                CompletableFuture.completedFuture(mockResponse);
+//
+//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+//
+//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+//        ClientListObjectsRequest request = new ClientListObjectsRequest()
+//                .type(DEFAULT_TYPE)
+//                .relation(DEFAULT_RELATION)
+//                .user(DEFAULT_USER);
+//
+//        ClientStreamedListObjectsOptions options = new ClientStreamedListObjectsOptions()
+//                .authorizationModelId("custom-model-id")
+//                .consistency(ConsistencyPreference.HIGHER_CONSISTENCY);
+//
+//        // When
+//        CompletableFuture<Void> future = fga.streamedListObjects(request, options, receivedObjects::add);
+//        future.get(); // Wait for completion
+//
+//        // Then
+//        assertEquals(1, receivedObjects.size());
+//        assertEquals("document:1", receivedObjects.get(0).getObject());
+//    }
+//
+//    @Test
+//    public void streamedListObjects_emptyStream() throws Exception {
+//        // Given
+//        Stream<String> streamResponse = Stream.empty();
+//
+//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+//                CompletableFuture.completedFuture(mockResponse);
+//
+//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+//
+//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+//        ClientListObjectsRequest request = new ClientListObjectsRequest()
+//                .type(DEFAULT_TYPE)
+//                .relation(DEFAULT_RELATION)
+//                .user(DEFAULT_USER);
+//
+//        // When
+//        CompletableFuture<Void> future = fga.streamedListObjects(request, receivedObjects::add);
+//        future.get(); // Wait for completion
+//
+//        // Then
+//        assertEquals(0, receivedObjects.size());
+//    }
+//
+//    @Test
+//    public void streamedListObjects_storeIdRequired() {
+//        // Given
+//        clientConfiguration.storeId(null);
+//        ClientListObjectsRequest request = new ClientListObjectsRequest()
+//                .type(DEFAULT_TYPE)
+//                .relation(DEFAULT_RELATION)
+//                .user(DEFAULT_USER);
+//
+//        // When/Then
+//        var exception = assertThrows(FgaInvalidParameterException.class, () -> {
+//            fga.streamedListObjects(request, response -> {});
+//        });
+//
+//        assertEquals(
+//                "Required parameter storeId was invalid when calling ClientConfiguration.", exception.getMessage());
+//    }
+//
+//    @Test
+//    public void streamedListObjects_errorHandling() throws Exception {
+//        // Given
+//        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
+//        String line2 = "{\"error\":{\"message\":\"Something went wrong\"}}";
+//        String line3 = "{\"result\":{\"object\":\"document:2\"}}";
+//        Stream<String> streamResponse = Stream.of(line1, line2, line3);
+//
+//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+//                CompletableFuture.completedFuture(mockResponse);
+//
+//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+//
+//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+//        List<Throwable> receivedErrors = new ArrayList<>();
+//        ClientListObjectsRequest request = new ClientListObjectsRequest()
+//                .type(DEFAULT_TYPE)
+//                .relation(DEFAULT_RELATION)
+//                .user(DEFAULT_USER);
+//
+//        // When
+//        CompletableFuture<Void> future =
+//                fga.streamedListObjects(request, null, receivedObjects::add, receivedErrors::add);
+//        future.get(); // Wait for completion
+//
+//        // Then
+//        assertEquals(2, receivedObjects.size());
+//        assertEquals("document:1", receivedObjects.get(0).getObject());
+//        assertEquals("document:2", receivedObjects.get(1).getObject());
+//        assertEquals(1, receivedErrors.size());
+//    }
+//
+//    @Test
+//    public void streamedListObjects_errorHandlingWithNullMessage() throws Exception {
+//        // Given - error with null message and no code
+//        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
+//        String line2 = "{\"error\":{}}"; // Empty error object (null message, null code)
+//        String line3 = "{\"error\":{\"code\":123}}"; // Error with code but null message
+//        Stream<String> streamResponse = Stream.of(line1, line2, line3);
+//
+//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+//                CompletableFuture.completedFuture(mockResponse);
+//
+//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+//
+//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+//        List<Throwable> receivedErrors = new ArrayList<>();
+//        ClientListObjectsRequest request = new ClientListObjectsRequest()
+//                .type(DEFAULT_TYPE)
+//                .relation(DEFAULT_RELATION)
+//                .user(DEFAULT_USER);
+//
+//        // When
+//        CompletableFuture<Void> future =
+//                fga.streamedListObjects(request, null, receivedObjects::add, receivedErrors::add);
+//        future.get(); // Wait for completion
+//
+//        // Then - should handle null messages gracefully without NPE
+//        assertEquals(1, receivedObjects.size());
+//        assertEquals(2, receivedErrors.size());
+//
+//        // Verify first error has a fallback message
+//        assertTrue(receivedErrors.get(0) instanceof dev.openfga.sdk.errors.ApiException);
+//        String firstErrorMsg = ((dev.openfga.sdk.errors.ApiException) receivedErrors.get(0)).getMessage();
+//        assertTrue(firstErrorMsg.contains("Stream error"));
+//        assertTrue(firstErrorMsg.contains("unknown"));
+//
+//        // Verify second error has code in message
+//        assertTrue(receivedErrors.get(1) instanceof dev.openfga.sdk.errors.ApiException);
+//        String secondErrorMsg = ((dev.openfga.sdk.errors.ApiException) receivedErrors.get(1)).getMessage();
+//        assertTrue(secondErrorMsg.contains("Stream error"));
+//        assertTrue(secondErrorMsg.contains("code 123"));
+//    }
+//
+//    @Test
+//    public void streamedListObjects_httpError() throws Exception {
+//        // Given
+//        Stream<String> streamResponse = Stream.empty();
+//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(400, streamResponse);
+//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+//                CompletableFuture.completedFuture(mockResponse);
+//
+//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+//
+//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+//        List<Throwable> receivedErrors = new ArrayList<>();
+//        ClientListObjectsRequest request = new ClientListObjectsRequest()
+//                .type(DEFAULT_TYPE)
+//                .relation(DEFAULT_RELATION)
+//                .user(DEFAULT_USER);
+//
+//        // When
+//        CompletableFuture<Void> future =
+//                fga.streamedListObjects(request, null, receivedObjects::add, receivedErrors::add);
+//
+//        try {
+//            future.get(); // Wait for completion - should fail
+//            fail("Expected exception");
+//        } catch (Exception e) {
+//            // Expected
+//        }
+//
+//        // Then
+//        assertEquals(0, receivedObjects.size());
+//        assertEquals(1, receivedErrors.size());
+//    }
+//
+//    @Test
+//    public void streamedListObjects_consumerInvocationCount() throws Exception {
+//        // Given
+//        int expectedCount = 100;
+//        List<String> lines = new ArrayList<>();
+//        for (int i = 0; i < expectedCount; i++) {
+//            lines.add(String.format("{\"result\":{\"object\":\"document:%d\"}}", i));
+//        }
+//        Stream<String> streamResponse = lines.stream();
+//
+//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+//                CompletableFuture.completedFuture(mockResponse);
+//
+//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+//
+//        AtomicInteger callCount = new AtomicInteger(0);
+//        ClientListObjectsRequest request = new ClientListObjectsRequest()
+//                .type(DEFAULT_TYPE)
+//                .relation(DEFAULT_RELATION)
+//                .user(DEFAULT_USER);
+//
+//        // When
+//        CompletableFuture<Void> future = fga.streamedListObjects(request, response -> callCount.incrementAndGet());
+//        future.get(); // Wait for completion
+//
+//        // Then
+//        assertEquals(expectedCount, callCount.get());
+//    }
+//
+//    @Test
+//    public void streamedListObjects_chainingWithOtherOperations() throws Exception {
+//        // Given
+//        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
+//        Stream<String> streamResponse = Stream.of(line1);
+//
+//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+//                CompletableFuture.completedFuture(mockResponse);
+//
+//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+//
+//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+//        ClientListObjectsRequest request = new ClientListObjectsRequest()
+//                .type(DEFAULT_TYPE)
+//                .relation(DEFAULT_RELATION)
+//                .user(DEFAULT_USER);
+//
+//        // When - Chain with other async operations
+//        AtomicInteger completionFlag = new AtomicInteger(0);
+//        CompletableFuture<Void> future = fga.streamedListObjects(request, receivedObjects::add)
+//                .thenRun(() -> completionFlag.set(1))
+//                .thenRun(() -> completionFlag.set(2));
+//
+//        future.get(); // Wait for all chained operations
+//
+//        // Then
+//        assertEquals(1, receivedObjects.size());
+//        assertEquals(2, completionFlag.get());
+//    }
+//
+//    @Test
+//    public void streamedListObjects_additionalHeadersPassedThrough() throws Exception {
+//        // Given
+//        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
+//        Stream<String> streamResponse = Stream.of(line1);
+//
+//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+//                CompletableFuture.completedFuture(mockResponse);
+//
+//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+//
+//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+//        ClientListObjectsRequest request = new ClientListObjectsRequest()
+//                .type(DEFAULT_TYPE)
+//                .relation(DEFAULT_RELATION)
+//                .user(DEFAULT_USER);
+//
+//        // Create options with additional headers
+//        Map<String, String> additionalHeaders = Map.of(
+//                "X-Custom-Header", "custom-value",
+//                "X-Request-ID", "test-request-123");
+//
+//        ClientStreamedListObjectsOptions options =
+//                new ClientStreamedListObjectsOptions().additionalHeaders(additionalHeaders);
+//
+//        // When
+//        CompletableFuture<Void> future = fga.streamedListObjects(request, options, receivedObjects::add);
+//        future.get(); // Wait for completion
+//
+//        // Then
+//        assertEquals(1, receivedObjects.size());
+//        assertEquals("document:1", receivedObjects.get(0).getObject());
+//
+//        // Verify that the HTTP client was called (which means headers were applied)
+//        verify(mockHttpClient, times(1)).sendAsync(any(), any());
+//    }
+//
+//    @Test
+//    public void streamedListObjects_preservesApiExceptionType() throws Exception {
+//        // Given - HTTP 400 error should create ApiException
+//        Stream<String> streamResponse = Stream.empty();
+//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(400, streamResponse);
+//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+//                CompletableFuture.completedFuture(mockResponse);
+//
+//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+//
+//        List<Throwable> receivedErrors = new ArrayList<>();
+//        ClientListObjectsRequest request = new ClientListObjectsRequest()
+//                .type(DEFAULT_TYPE)
+//                .relation(DEFAULT_RELATION)
+//                .user(DEFAULT_USER);
+//
+//        // When
+//        CompletableFuture<Void> future = fga.streamedListObjects(request, null, obj -> {}, receivedErrors::add);
+//
+//        try {
+//            future.get();
+//            fail("Expected exception");
+//        } catch (Exception e) {
+//            // Expected to fail
+//        }
+//
+//        // Then - verify the error consumer received the original ApiException, not wrapped
+//        assertEquals(1, receivedErrors.size());
+//        Throwable error = receivedErrors.get(0);
+//        assertTrue(
+//                error instanceof dev.openfga.sdk.errors.ApiException,
+//                "Expected ApiException but got " + error.getClass().getName());
+//        dev.openfga.sdk.errors.ApiException apiException = (dev.openfga.sdk.errors.ApiException) error;
+//        assertEquals(400, apiException.getStatusCode());
+//    }
+//
+//    private HttpResponse<Stream<String>> createMockStreamResponse(int statusCode, Stream<String> body) {
+//        HttpResponse<Stream<String>> mockResponse = mock(HttpResponse.class);
+//        when(mockResponse.statusCode()).thenReturn(statusCode);
+//        when(mockResponse.body()).thenReturn(body);
+//
+//        // Create mock headers
+//        HttpHeaders mockHeaders = mock(HttpHeaders.class);
+//        when(mockHeaders.map()).thenReturn(Map.of("content-type", List.of("application/json")));
+//        when(mockResponse.headers()).thenReturn(mockHeaders);
+//
+//        return mockResponse;
+//    }
+//}

From c227731df9121b103cc04f63b0514fbef097c6a5 Mon Sep 17 00:00:00 2001
From: SoulPancake <angbpy@gmail.com>
Date: Fri, 5 Dec 2025 16:27:44 +0530
Subject: [PATCH 2/3] fix: spotless fmt

---
 .../client/OpenFgaClientIntegrationTest.java  |  1 -
 .../api/client/StreamedListObjectsTest.java   | 62 +++++++++----------
 2 files changed, 31 insertions(+), 32 deletions(-)

diff --git a/src/test-integration/java/dev/openfga/sdk/api/client/OpenFgaClientIntegrationTest.java b/src/test-integration/java/dev/openfga/sdk/api/client/OpenFgaClientIntegrationTest.java
index 5d98d463..4b2727aa 100644
--- a/src/test-integration/java/dev/openfga/sdk/api/client/OpenFgaClientIntegrationTest.java
+++ b/src/test-integration/java/dev/openfga/sdk/api/client/OpenFgaClientIntegrationTest.java
@@ -11,7 +11,6 @@
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.util.List;
-import java.util.concurrent.CompletableFuture;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
diff --git a/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java b/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java
index a3a4f45c..55d9ad73 100644
--- a/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java
+++ b/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java
@@ -1,36 +1,36 @@
 // NOTE: This test is temporarily commented out as the streamedListObjects API is not yet available for public use.
 // It will be enabled in a future release.
 
-//package dev.openfga.sdk.api.client;
-//
-//import static org.junit.jupiter.api.Assertions.*;
-//import static org.mockito.ArgumentMatchers.any;
-//import static org.mockito.Mockito.*;
-//
-//import com.fasterxml.jackson.databind.ObjectMapper;
-//import dev.openfga.sdk.api.client.model.ClientListObjectsRequest;
-//import dev.openfga.sdk.api.client.model.ClientStreamedListObjectsOptions;
-//import dev.openfga.sdk.api.configuration.ClientConfiguration;
-//import dev.openfga.sdk.api.configuration.Credentials;
-//import dev.openfga.sdk.api.model.ConsistencyPreference;
-//import dev.openfga.sdk.api.model.StreamedListObjectsResponse;
-//import dev.openfga.sdk.constants.FgaConstants;
-//import dev.openfga.sdk.errors.FgaInvalidParameterException;
-//import java.net.http.HttpClient;
-//import java.net.http.HttpHeaders;
-//import java.net.http.HttpResponse;
-//import java.time.Duration;
-//import java.util.ArrayList;
-//import java.util.List;
-//import java.util.Map;
-//import java.util.concurrent.CompletableFuture;
-//import java.util.concurrent.atomic.AtomicInteger;
-//import java.util.stream.Stream;
-//import org.junit.jupiter.api.BeforeEach;
-//import org.junit.jupiter.api.Test;
-//
-///** Tests for streaming list objects functionality with CompletableFuture. */
-//public class StreamedListObjectsTest {
+// package dev.openfga.sdk.api.client;
+//
+// import static org.junit.jupiter.api.Assertions.*;
+// import static org.mockito.ArgumentMatchers.any;
+// import static org.mockito.Mockito.*;
+//
+// import com.fasterxml.jackson.databind.ObjectMapper;
+// import dev.openfga.sdk.api.client.model.ClientListObjectsRequest;
+// import dev.openfga.sdk.api.client.model.ClientStreamedListObjectsOptions;
+// import dev.openfga.sdk.api.configuration.ClientConfiguration;
+// import dev.openfga.sdk.api.configuration.Credentials;
+// import dev.openfga.sdk.api.model.ConsistencyPreference;
+// import dev.openfga.sdk.api.model.StreamedListObjectsResponse;
+// import dev.openfga.sdk.constants.FgaConstants;
+// import dev.openfga.sdk.errors.FgaInvalidParameterException;
+// import java.net.http.HttpClient;
+// import java.net.http.HttpHeaders;
+// import java.net.http.HttpResponse;
+// import java.time.Duration;
+// import java.util.ArrayList;
+// import java.util.List;
+// import java.util.Map;
+// import java.util.concurrent.CompletableFuture;
+// import java.util.concurrent.atomic.AtomicInteger;
+// import java.util.stream.Stream;
+// import org.junit.jupiter.api.BeforeEach;
+// import org.junit.jupiter.api.Test;
+//
+/// ** Tests for streaming list objects functionality with CompletableFuture. */
+// public class StreamedListObjectsTest {
 //    private static final String DEFAULT_STORE_ID = "01YCP46JKYM8FJCQ37NMBYHE5X";
 //    private static final String DEFAULT_AUTH_MODEL_ID = "01G5JAVJ41T49E9TT3SKVS7X1J";
 //    private static final String DEFAULT_USER = "user:81684243-9356-4421-8fbf-a4f8d36aa31b";
@@ -426,4 +426,4 @@
 //
 //        return mockResponse;
 //    }
-//}
+// }

From e75586f5abdfbda1ba1183f0831bcdf41a761206 Mon Sep 17 00:00:00 2001
From: SoulPancake <angbpy@gmail.com>
Date: Fri, 5 Dec 2025 18:08:17 +0530
Subject: [PATCH 3/3] feat: use disabled annotations instead of comments

---
 .../openfga/sdk/api/client/OpenFgaClient.java |   6 +-
 .../client/OpenFgaClientIntegrationTest.java  |   7 +-
 .../api/client/StreamedListObjectsTest.java   | 857 +++++++++---------
 3 files changed, 434 insertions(+), 436 deletions(-)

diff --git a/src/main/java/dev/openfga/sdk/api/client/OpenFgaClient.java b/src/main/java/dev/openfga/sdk/api/client/OpenFgaClient.java
index 70ac9df7..8dd17c26 100644
--- a/src/main/java/dev/openfga/sdk/api/client/OpenFgaClient.java
+++ b/src/main/java/dev/openfga/sdk/api/client/OpenFgaClient.java
@@ -1131,7 +1131,7 @@ public CompletableFuture<ClientListObjectsResponse> listObjects(
      * @return CompletableFuture<Void> that completes when streaming finishes
      * @throws FgaInvalidParameterException When the Store ID is null, empty, or whitespace, or consumer is null
      */
-    private CompletableFuture<Void> streamedListObjects(
+    CompletableFuture<Void> streamedListObjects(
             ClientListObjectsRequest request, Consumer<StreamedListObjectsResponse> consumer)
             throws FgaInvalidParameterException {
         if (consumer == null) {
@@ -1171,7 +1171,7 @@ private CompletableFuture<Void> streamedListObjects(
      * @return CompletableFuture<Void> that completes when streaming finishes
      * @throws FgaInvalidParameterException When the Store ID is null, empty, or whitespace, or consumer is null
      */
-    private CompletableFuture<Void> streamedListObjects(
+    CompletableFuture<Void> streamedListObjects(
             ClientListObjectsRequest request,
             ClientStreamedListObjectsOptions options,
             Consumer<StreamedListObjectsResponse> consumer)
@@ -1211,7 +1211,7 @@ private CompletableFuture<Void> streamedListObjects(
      * @return CompletableFuture<Void> that completes when streaming finishes or exceptionally on error
      * @throws FgaInvalidParameterException When the Store ID is null, empty, or whitespace, or consumer is null
      */
-    private CompletableFuture<Void> streamedListObjects(
+    CompletableFuture<Void> streamedListObjects(
             ClientListObjectsRequest request,
             ClientStreamedListObjectsOptions options,
             Consumer<StreamedListObjectsResponse> consumer,
diff --git a/src/test-integration/java/dev/openfga/sdk/api/client/OpenFgaClientIntegrationTest.java b/src/test-integration/java/dev/openfga/sdk/api/client/OpenFgaClientIntegrationTest.java
index 4b2727aa..f643a275 100644
--- a/src/test-integration/java/dev/openfga/sdk/api/client/OpenFgaClientIntegrationTest.java
+++ b/src/test-integration/java/dev/openfga/sdk/api/client/OpenFgaClientIntegrationTest.java
@@ -11,8 +11,10 @@
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.util.List;
+import java.util.concurrent.CompletableFuture;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInstance;
 import org.junit.jupiter.api.TestInstance.Lifecycle;
@@ -372,10 +374,8 @@ private String writeAuthModel(String storeId) throws Exception {
         return response.getAuthorizationModelId();
     }
 
-    // NOTE: This test is temporarily commented out as the streamedListObjects API is not yet available for public use.
-    // It will be enabled in a future release.
-    /*
     @Test
+    @Disabled("streamedListObjects is private for now")
     public void streamedListObjects() throws Exception {
         // Given - Create a single store for all streaming tests
         String storeId = createStore(thisTestName());
@@ -466,7 +466,6 @@ public void streamedListObjects() throws Exception {
         assertEquals(20, chainTestObjects.size());
         assertTrue(chainedOperationExecuted.get());
     }
-    */
 
     /** Get the name of the test that invokes this function. Returned in the form: "$class.$fn" */
     private String thisTestName() {
diff --git a/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java b/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java
index 55d9ad73..bd4f2839 100644
--- a/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java
+++ b/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java
@@ -1,429 +1,428 @@
-// NOTE: This test is temporarily commented out as the streamedListObjects API is not yet available for public use.
-// It will be enabled in a future release.
-
-// package dev.openfga.sdk.api.client;
-//
-// import static org.junit.jupiter.api.Assertions.*;
-// import static org.mockito.ArgumentMatchers.any;
-// import static org.mockito.Mockito.*;
-//
-// import com.fasterxml.jackson.databind.ObjectMapper;
-// import dev.openfga.sdk.api.client.model.ClientListObjectsRequest;
-// import dev.openfga.sdk.api.client.model.ClientStreamedListObjectsOptions;
-// import dev.openfga.sdk.api.configuration.ClientConfiguration;
-// import dev.openfga.sdk.api.configuration.Credentials;
-// import dev.openfga.sdk.api.model.ConsistencyPreference;
-// import dev.openfga.sdk.api.model.StreamedListObjectsResponse;
-// import dev.openfga.sdk.constants.FgaConstants;
-// import dev.openfga.sdk.errors.FgaInvalidParameterException;
-// import java.net.http.HttpClient;
-// import java.net.http.HttpHeaders;
-// import java.net.http.HttpResponse;
-// import java.time.Duration;
-// import java.util.ArrayList;
-// import java.util.List;
-// import java.util.Map;
-// import java.util.concurrent.CompletableFuture;
-// import java.util.concurrent.atomic.AtomicInteger;
-// import java.util.stream.Stream;
-// import org.junit.jupiter.api.BeforeEach;
-// import org.junit.jupiter.api.Test;
-//
-/// ** Tests for streaming list objects functionality with CompletableFuture. */
-// public class StreamedListObjectsTest {
-//    private static final String DEFAULT_STORE_ID = "01YCP46JKYM8FJCQ37NMBYHE5X";
-//    private static final String DEFAULT_AUTH_MODEL_ID = "01G5JAVJ41T49E9TT3SKVS7X1J";
-//    private static final String DEFAULT_USER = "user:81684243-9356-4421-8fbf-a4f8d36aa31b";
-//    private static final String DEFAULT_RELATION = "owner";
-//    private static final String DEFAULT_TYPE = "document";
-//
-//    private OpenFgaClient fga;
-//    private ClientConfiguration clientConfiguration;
-//    private HttpClient mockHttpClient;
-//    private ApiClient mockApiClient;
-//
-//    @BeforeEach
-//    public void beforeEachTest() throws Exception {
-//        mockHttpClient = mock(HttpClient.class);
-//        var mockHttpClientBuilder = mock(HttpClient.Builder.class);
-//        when(mockHttpClientBuilder.executor(any())).thenReturn(mockHttpClientBuilder);
-//        when(mockHttpClientBuilder.build()).thenReturn(mockHttpClient);
-//
-//        clientConfiguration = new ClientConfiguration()
-//                .storeId(DEFAULT_STORE_ID)
-//                .authorizationModelId(DEFAULT_AUTH_MODEL_ID)
-//                .apiUrl(FgaConstants.TEST_API_URL)
-//                .credentials(new Credentials())
-//                .readTimeout(Duration.ofMillis(250));
-//
-//        mockApiClient = mock(ApiClient.class);
-//        when(mockApiClient.getHttpClient()).thenReturn(mockHttpClient);
-//        when(mockApiClient.getObjectMapper()).thenReturn(new ObjectMapper());
-//        when(mockApiClient.getHttpClientBuilder()).thenReturn(mockHttpClientBuilder);
-//
-//        fga = new OpenFgaClient(clientConfiguration, mockApiClient);
-//    }
-//
-//    @Test
-//    public void streamedListObjects_success() throws Exception {
-//        // Given
-//        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
-//        String line2 = "{\"result\":{\"object\":\"document:2\"}}";
-//        String line3 = "{\"result\":{\"object\":\"document:3\"}}";
-//        Stream<String> streamResponse = Stream.of(line1, line2, line3);
-//
-//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-//                CompletableFuture.completedFuture(mockResponse);
-//
-//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-//
-//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-//        ClientListObjectsRequest request = new ClientListObjectsRequest()
-//                .type(DEFAULT_TYPE)
-//                .relation(DEFAULT_RELATION)
-//                .user(DEFAULT_USER);
-//
-//        // When
-//        CompletableFuture<Void> future = fga.streamedListObjects(request, receivedObjects::add);
-//        future.get(); // Wait for completion
-//
-//        // Then
-//        assertEquals(3, receivedObjects.size());
-//        assertEquals("document:1", receivedObjects.get(0).getObject());
-//        assertEquals("document:2", receivedObjects.get(1).getObject());
-//        assertEquals("document:3", receivedObjects.get(2).getObject());
-//        verify(mockHttpClient, times(1)).sendAsync(any(), any());
-//    }
-//
-//    @Test
-//    public void streamedListObjects_withOptions() throws Exception {
-//        // Given
-//        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
-//        Stream<String> streamResponse = Stream.of(line1);
-//
-//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-//                CompletableFuture.completedFuture(mockResponse);
-//
-//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-//
-//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-//        ClientListObjectsRequest request = new ClientListObjectsRequest()
-//                .type(DEFAULT_TYPE)
-//                .relation(DEFAULT_RELATION)
-//                .user(DEFAULT_USER);
-//
-//        ClientStreamedListObjectsOptions options = new ClientStreamedListObjectsOptions()
-//                .authorizationModelId("custom-model-id")
-//                .consistency(ConsistencyPreference.HIGHER_CONSISTENCY);
-//
-//        // When
-//        CompletableFuture<Void> future = fga.streamedListObjects(request, options, receivedObjects::add);
-//        future.get(); // Wait for completion
-//
-//        // Then
-//        assertEquals(1, receivedObjects.size());
-//        assertEquals("document:1", receivedObjects.get(0).getObject());
-//    }
-//
-//    @Test
-//    public void streamedListObjects_emptyStream() throws Exception {
-//        // Given
-//        Stream<String> streamResponse = Stream.empty();
-//
-//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-//                CompletableFuture.completedFuture(mockResponse);
-//
-//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-//
-//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-//        ClientListObjectsRequest request = new ClientListObjectsRequest()
-//                .type(DEFAULT_TYPE)
-//                .relation(DEFAULT_RELATION)
-//                .user(DEFAULT_USER);
-//
-//        // When
-//        CompletableFuture<Void> future = fga.streamedListObjects(request, receivedObjects::add);
-//        future.get(); // Wait for completion
-//
-//        // Then
-//        assertEquals(0, receivedObjects.size());
-//    }
-//
-//    @Test
-//    public void streamedListObjects_storeIdRequired() {
-//        // Given
-//        clientConfiguration.storeId(null);
-//        ClientListObjectsRequest request = new ClientListObjectsRequest()
-//                .type(DEFAULT_TYPE)
-//                .relation(DEFAULT_RELATION)
-//                .user(DEFAULT_USER);
-//
-//        // When/Then
-//        var exception = assertThrows(FgaInvalidParameterException.class, () -> {
-//            fga.streamedListObjects(request, response -> {});
-//        });
-//
-//        assertEquals(
-//                "Required parameter storeId was invalid when calling ClientConfiguration.", exception.getMessage());
-//    }
-//
-//    @Test
-//    public void streamedListObjects_errorHandling() throws Exception {
-//        // Given
-//        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
-//        String line2 = "{\"error\":{\"message\":\"Something went wrong\"}}";
-//        String line3 = "{\"result\":{\"object\":\"document:2\"}}";
-//        Stream<String> streamResponse = Stream.of(line1, line2, line3);
-//
-//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-//                CompletableFuture.completedFuture(mockResponse);
-//
-//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-//
-//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-//        List<Throwable> receivedErrors = new ArrayList<>();
-//        ClientListObjectsRequest request = new ClientListObjectsRequest()
-//                .type(DEFAULT_TYPE)
-//                .relation(DEFAULT_RELATION)
-//                .user(DEFAULT_USER);
-//
-//        // When
-//        CompletableFuture<Void> future =
-//                fga.streamedListObjects(request, null, receivedObjects::add, receivedErrors::add);
-//        future.get(); // Wait for completion
-//
-//        // Then
-//        assertEquals(2, receivedObjects.size());
-//        assertEquals("document:1", receivedObjects.get(0).getObject());
-//        assertEquals("document:2", receivedObjects.get(1).getObject());
-//        assertEquals(1, receivedErrors.size());
-//    }
-//
-//    @Test
-//    public void streamedListObjects_errorHandlingWithNullMessage() throws Exception {
-//        // Given - error with null message and no code
-//        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
-//        String line2 = "{\"error\":{}}"; // Empty error object (null message, null code)
-//        String line3 = "{\"error\":{\"code\":123}}"; // Error with code but null message
-//        Stream<String> streamResponse = Stream.of(line1, line2, line3);
-//
-//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-//                CompletableFuture.completedFuture(mockResponse);
-//
-//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-//
-//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-//        List<Throwable> receivedErrors = new ArrayList<>();
-//        ClientListObjectsRequest request = new ClientListObjectsRequest()
-//                .type(DEFAULT_TYPE)
-//                .relation(DEFAULT_RELATION)
-//                .user(DEFAULT_USER);
-//
-//        // When
-//        CompletableFuture<Void> future =
-//                fga.streamedListObjects(request, null, receivedObjects::add, receivedErrors::add);
-//        future.get(); // Wait for completion
-//
-//        // Then - should handle null messages gracefully without NPE
-//        assertEquals(1, receivedObjects.size());
-//        assertEquals(2, receivedErrors.size());
-//
-//        // Verify first error has a fallback message
-//        assertTrue(receivedErrors.get(0) instanceof dev.openfga.sdk.errors.ApiException);
-//        String firstErrorMsg = ((dev.openfga.sdk.errors.ApiException) receivedErrors.get(0)).getMessage();
-//        assertTrue(firstErrorMsg.contains("Stream error"));
-//        assertTrue(firstErrorMsg.contains("unknown"));
-//
-//        // Verify second error has code in message
-//        assertTrue(receivedErrors.get(1) instanceof dev.openfga.sdk.errors.ApiException);
-//        String secondErrorMsg = ((dev.openfga.sdk.errors.ApiException) receivedErrors.get(1)).getMessage();
-//        assertTrue(secondErrorMsg.contains("Stream error"));
-//        assertTrue(secondErrorMsg.contains("code 123"));
-//    }
-//
-//    @Test
-//    public void streamedListObjects_httpError() throws Exception {
-//        // Given
-//        Stream<String> streamResponse = Stream.empty();
-//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(400, streamResponse);
-//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-//                CompletableFuture.completedFuture(mockResponse);
-//
-//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-//
-//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-//        List<Throwable> receivedErrors = new ArrayList<>();
-//        ClientListObjectsRequest request = new ClientListObjectsRequest()
-//                .type(DEFAULT_TYPE)
-//                .relation(DEFAULT_RELATION)
-//                .user(DEFAULT_USER);
-//
-//        // When
-//        CompletableFuture<Void> future =
-//                fga.streamedListObjects(request, null, receivedObjects::add, receivedErrors::add);
-//
-//        try {
-//            future.get(); // Wait for completion - should fail
-//            fail("Expected exception");
-//        } catch (Exception e) {
-//            // Expected
-//        }
-//
-//        // Then
-//        assertEquals(0, receivedObjects.size());
-//        assertEquals(1, receivedErrors.size());
-//    }
-//
-//    @Test
-//    public void streamedListObjects_consumerInvocationCount() throws Exception {
-//        // Given
-//        int expectedCount = 100;
-//        List<String> lines = new ArrayList<>();
-//        for (int i = 0; i < expectedCount; i++) {
-//            lines.add(String.format("{\"result\":{\"object\":\"document:%d\"}}", i));
-//        }
-//        Stream<String> streamResponse = lines.stream();
-//
-//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-//                CompletableFuture.completedFuture(mockResponse);
-//
-//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-//
-//        AtomicInteger callCount = new AtomicInteger(0);
-//        ClientListObjectsRequest request = new ClientListObjectsRequest()
-//                .type(DEFAULT_TYPE)
-//                .relation(DEFAULT_RELATION)
-//                .user(DEFAULT_USER);
-//
-//        // When
-//        CompletableFuture<Void> future = fga.streamedListObjects(request, response -> callCount.incrementAndGet());
-//        future.get(); // Wait for completion
-//
-//        // Then
-//        assertEquals(expectedCount, callCount.get());
-//    }
-//
-//    @Test
-//    public void streamedListObjects_chainingWithOtherOperations() throws Exception {
-//        // Given
-//        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
-//        Stream<String> streamResponse = Stream.of(line1);
-//
-//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-//                CompletableFuture.completedFuture(mockResponse);
-//
-//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-//
-//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-//        ClientListObjectsRequest request = new ClientListObjectsRequest()
-//                .type(DEFAULT_TYPE)
-//                .relation(DEFAULT_RELATION)
-//                .user(DEFAULT_USER);
-//
-//        // When - Chain with other async operations
-//        AtomicInteger completionFlag = new AtomicInteger(0);
-//        CompletableFuture<Void> future = fga.streamedListObjects(request, receivedObjects::add)
-//                .thenRun(() -> completionFlag.set(1))
-//                .thenRun(() -> completionFlag.set(2));
-//
-//        future.get(); // Wait for all chained operations
-//
-//        // Then
-//        assertEquals(1, receivedObjects.size());
-//        assertEquals(2, completionFlag.get());
-//    }
-//
-//    @Test
-//    public void streamedListObjects_additionalHeadersPassedThrough() throws Exception {
-//        // Given
-//        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
-//        Stream<String> streamResponse = Stream.of(line1);
-//
-//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
-//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-//                CompletableFuture.completedFuture(mockResponse);
-//
-//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-//
-//        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
-//        ClientListObjectsRequest request = new ClientListObjectsRequest()
-//                .type(DEFAULT_TYPE)
-//                .relation(DEFAULT_RELATION)
-//                .user(DEFAULT_USER);
-//
-//        // Create options with additional headers
-//        Map<String, String> additionalHeaders = Map.of(
-//                "X-Custom-Header", "custom-value",
-//                "X-Request-ID", "test-request-123");
-//
-//        ClientStreamedListObjectsOptions options =
-//                new ClientStreamedListObjectsOptions().additionalHeaders(additionalHeaders);
-//
-//        // When
-//        CompletableFuture<Void> future = fga.streamedListObjects(request, options, receivedObjects::add);
-//        future.get(); // Wait for completion
-//
-//        // Then
-//        assertEquals(1, receivedObjects.size());
-//        assertEquals("document:1", receivedObjects.get(0).getObject());
-//
-//        // Verify that the HTTP client was called (which means headers were applied)
-//        verify(mockHttpClient, times(1)).sendAsync(any(), any());
-//    }
-//
-//    @Test
-//    public void streamedListObjects_preservesApiExceptionType() throws Exception {
-//        // Given - HTTP 400 error should create ApiException
-//        Stream<String> streamResponse = Stream.empty();
-//        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(400, streamResponse);
-//        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
-//                CompletableFuture.completedFuture(mockResponse);
-//
-//        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
-//
-//        List<Throwable> receivedErrors = new ArrayList<>();
-//        ClientListObjectsRequest request = new ClientListObjectsRequest()
-//                .type(DEFAULT_TYPE)
-//                .relation(DEFAULT_RELATION)
-//                .user(DEFAULT_USER);
-//
-//        // When
-//        CompletableFuture<Void> future = fga.streamedListObjects(request, null, obj -> {}, receivedErrors::add);
-//
-//        try {
-//            future.get();
-//            fail("Expected exception");
-//        } catch (Exception e) {
-//            // Expected to fail
-//        }
-//
-//        // Then - verify the error consumer received the original ApiException, not wrapped
-//        assertEquals(1, receivedErrors.size());
-//        Throwable error = receivedErrors.get(0);
-//        assertTrue(
-//                error instanceof dev.openfga.sdk.errors.ApiException,
-//                "Expected ApiException but got " + error.getClass().getName());
-//        dev.openfga.sdk.errors.ApiException apiException = (dev.openfga.sdk.errors.ApiException) error;
-//        assertEquals(400, apiException.getStatusCode());
-//    }
-//
-//    private HttpResponse<Stream<String>> createMockStreamResponse(int statusCode, Stream<String> body) {
-//        HttpResponse<Stream<String>> mockResponse = mock(HttpResponse.class);
-//        when(mockResponse.statusCode()).thenReturn(statusCode);
-//        when(mockResponse.body()).thenReturn(body);
-//
-//        // Create mock headers
-//        HttpHeaders mockHeaders = mock(HttpHeaders.class);
-//        when(mockHeaders.map()).thenReturn(Map.of("content-type", List.of("application/json")));
-//        when(mockResponse.headers()).thenReturn(mockHeaders);
-//
-//        return mockResponse;
-//    }
-// }
+package dev.openfga.sdk.api.client;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.*;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import dev.openfga.sdk.api.client.model.ClientListObjectsRequest;
+import dev.openfga.sdk.api.client.model.ClientStreamedListObjectsOptions;
+import dev.openfga.sdk.api.configuration.ClientConfiguration;
+import dev.openfga.sdk.api.configuration.Credentials;
+import dev.openfga.sdk.api.model.ConsistencyPreference;
+import dev.openfga.sdk.api.model.StreamedListObjectsResponse;
+import dev.openfga.sdk.constants.FgaConstants;
+import dev.openfga.sdk.errors.FgaInvalidParameterException;
+import java.net.http.HttpClient;
+import java.net.http.HttpHeaders;
+import java.net.http.HttpResponse;
+import java.time.Duration;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.stream.Stream;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
+
+/** Tests for streaming list objects functionality with CompletableFuture. */
+@Disabled("streamedListObjects is private for now")
+public class StreamedListObjectsTest {
+    private static final String DEFAULT_STORE_ID = "01YCP46JKYM8FJCQ37NMBYHE5X";
+    private static final String DEFAULT_AUTH_MODEL_ID = "01G5JAVJ41T49E9TT3SKVS7X1J";
+    private static final String DEFAULT_USER = "user:81684243-9356-4421-8fbf-a4f8d36aa31b";
+    private static final String DEFAULT_RELATION = "owner";
+    private static final String DEFAULT_TYPE = "document";
+
+    private OpenFgaClient fga;
+    private ClientConfiguration clientConfiguration;
+    private HttpClient mockHttpClient;
+    private ApiClient mockApiClient;
+
+    @BeforeEach
+    public void beforeEachTest() throws Exception {
+        mockHttpClient = mock(HttpClient.class);
+        var mockHttpClientBuilder = mock(HttpClient.Builder.class);
+        when(mockHttpClientBuilder.executor(any())).thenReturn(mockHttpClientBuilder);
+        when(mockHttpClientBuilder.build()).thenReturn(mockHttpClient);
+
+        clientConfiguration = new ClientConfiguration()
+                .storeId(DEFAULT_STORE_ID)
+                .authorizationModelId(DEFAULT_AUTH_MODEL_ID)
+                .apiUrl(FgaConstants.TEST_API_URL)
+                .credentials(new Credentials())
+                .readTimeout(Duration.ofMillis(250));
+
+        mockApiClient = mock(ApiClient.class);
+        when(mockApiClient.getHttpClient()).thenReturn(mockHttpClient);
+        when(mockApiClient.getObjectMapper()).thenReturn(new ObjectMapper());
+        when(mockApiClient.getHttpClientBuilder()).thenReturn(mockHttpClientBuilder);
+
+        fga = new OpenFgaClient(clientConfiguration, mockApiClient);
+    }
+
+    @Test
+    public void streamedListObjects_success() throws Exception {
+        // Given
+        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
+        String line2 = "{\"result\":{\"object\":\"document:2\"}}";
+        String line3 = "{\"result\":{\"object\":\"document:3\"}}";
+        Stream<String> streamResponse = Stream.of(line1, line2, line3);
+
+        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+                CompletableFuture.completedFuture(mockResponse);
+
+        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+
+        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+        ClientListObjectsRequest request = new ClientListObjectsRequest()
+                .type(DEFAULT_TYPE)
+                .relation(DEFAULT_RELATION)
+                .user(DEFAULT_USER);
+
+        // When
+        CompletableFuture<Void> future = fga.streamedListObjects(request, receivedObjects::add);
+        future.get(); // Wait for completion
+
+        // Then
+        assertEquals(3, receivedObjects.size());
+        assertEquals("document:1", receivedObjects.get(0).getObject());
+        assertEquals("document:2", receivedObjects.get(1).getObject());
+        assertEquals("document:3", receivedObjects.get(2).getObject());
+        verify(mockHttpClient, times(1)).sendAsync(any(), any());
+    }
+
+    @Test
+    public void streamedListObjects_withOptions() throws Exception {
+        // Given
+        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
+        Stream<String> streamResponse = Stream.of(line1);
+
+        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+                CompletableFuture.completedFuture(mockResponse);
+
+        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+
+        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+        ClientListObjectsRequest request = new ClientListObjectsRequest()
+                .type(DEFAULT_TYPE)
+                .relation(DEFAULT_RELATION)
+                .user(DEFAULT_USER);
+
+        ClientStreamedListObjectsOptions options = new ClientStreamedListObjectsOptions()
+                .authorizationModelId("custom-model-id")
+                .consistency(ConsistencyPreference.HIGHER_CONSISTENCY);
+
+        // When
+        CompletableFuture<Void> future = fga.streamedListObjects(request, options, receivedObjects::add);
+        future.get(); // Wait for completion
+
+        // Then
+        assertEquals(1, receivedObjects.size());
+        assertEquals("document:1", receivedObjects.get(0).getObject());
+    }
+
+    @Test
+    public void streamedListObjects_emptyStream() throws Exception {
+        // Given
+        Stream<String> streamResponse = Stream.empty();
+
+        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+                CompletableFuture.completedFuture(mockResponse);
+
+        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+
+        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+        ClientListObjectsRequest request = new ClientListObjectsRequest()
+                .type(DEFAULT_TYPE)
+                .relation(DEFAULT_RELATION)
+                .user(DEFAULT_USER);
+
+        // When
+        CompletableFuture<Void> future = fga.streamedListObjects(request, receivedObjects::add);
+        future.get(); // Wait for completion
+
+        // Then
+        assertEquals(0, receivedObjects.size());
+    }
+
+    @Test
+    public void streamedListObjects_storeIdRequired() {
+        // Given
+        clientConfiguration.storeId(null);
+        ClientListObjectsRequest request = new ClientListObjectsRequest()
+                .type(DEFAULT_TYPE)
+                .relation(DEFAULT_RELATION)
+                .user(DEFAULT_USER);
+
+        // When/Then
+        var exception = assertThrows(FgaInvalidParameterException.class, () -> {
+            fga.streamedListObjects(request, response -> {});
+        });
+
+        assertEquals(
+                "Required parameter storeId was invalid when calling ClientConfiguration.", exception.getMessage());
+    }
+
+    @Test
+    public void streamedListObjects_errorHandling() throws Exception {
+        // Given
+        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
+        String line2 = "{\"error\":{\"message\":\"Something went wrong\"}}";
+        String line3 = "{\"result\":{\"object\":\"document:2\"}}";
+        Stream<String> streamResponse = Stream.of(line1, line2, line3);
+
+        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+                CompletableFuture.completedFuture(mockResponse);
+
+        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+
+        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+        List<Throwable> receivedErrors = new ArrayList<>();
+        ClientListObjectsRequest request = new ClientListObjectsRequest()
+                .type(DEFAULT_TYPE)
+                .relation(DEFAULT_RELATION)
+                .user(DEFAULT_USER);
+
+        // When
+        CompletableFuture<Void> future =
+                fga.streamedListObjects(request, null, receivedObjects::add, receivedErrors::add);
+        future.get(); // Wait for completion
+
+        // Then
+        assertEquals(2, receivedObjects.size());
+        assertEquals("document:1", receivedObjects.get(0).getObject());
+        assertEquals("document:2", receivedObjects.get(1).getObject());
+        assertEquals(1, receivedErrors.size());
+    }
+
+    @Test
+    public void streamedListObjects_errorHandlingWithNullMessage() throws Exception {
+        // Given - error with null message and no code
+        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
+        String line2 = "{\"error\":{}}"; // Empty error object (null message, null code)
+        String line3 = "{\"error\":{\"code\":123}}"; // Error with code but null message
+        Stream<String> streamResponse = Stream.of(line1, line2, line3);
+
+        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+                CompletableFuture.completedFuture(mockResponse);
+
+        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+
+        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+        List<Throwable> receivedErrors = new ArrayList<>();
+        ClientListObjectsRequest request = new ClientListObjectsRequest()
+                .type(DEFAULT_TYPE)
+                .relation(DEFAULT_RELATION)
+                .user(DEFAULT_USER);
+
+        // When
+        CompletableFuture<Void> future =
+                fga.streamedListObjects(request, null, receivedObjects::add, receivedErrors::add);
+        future.get(); // Wait for completion
+
+        // Then - should handle null messages gracefully without NPE
+        assertEquals(1, receivedObjects.size());
+        assertEquals(2, receivedErrors.size());
+
+        // Verify first error has a fallback message
+        assertTrue(receivedErrors.get(0) instanceof dev.openfga.sdk.errors.ApiException);
+        String firstErrorMsg = ((dev.openfga.sdk.errors.ApiException) receivedErrors.get(0)).getMessage();
+        assertTrue(firstErrorMsg.contains("Stream error"));
+        assertTrue(firstErrorMsg.contains("unknown"));
+
+        // Verify second error has code in message
+        assertTrue(receivedErrors.get(1) instanceof dev.openfga.sdk.errors.ApiException);
+        String secondErrorMsg = ((dev.openfga.sdk.errors.ApiException) receivedErrors.get(1)).getMessage();
+        assertTrue(secondErrorMsg.contains("Stream error"));
+        assertTrue(secondErrorMsg.contains("code 123"));
+    }
+
+    @Test
+    public void streamedListObjects_httpError() throws Exception {
+        // Given
+        Stream<String> streamResponse = Stream.empty();
+        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(400, streamResponse);
+        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+                CompletableFuture.completedFuture(mockResponse);
+
+        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+
+        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+        List<Throwable> receivedErrors = new ArrayList<>();
+        ClientListObjectsRequest request = new ClientListObjectsRequest()
+                .type(DEFAULT_TYPE)
+                .relation(DEFAULT_RELATION)
+                .user(DEFAULT_USER);
+
+        // When
+        CompletableFuture<Void> future =
+                fga.streamedListObjects(request, null, receivedObjects::add, receivedErrors::add);
+
+        try {
+            future.get(); // Wait for completion - should fail
+            fail("Expected exception");
+        } catch (Exception e) {
+            // Expected
+        }
+
+        // Then
+        assertEquals(0, receivedObjects.size());
+        assertEquals(1, receivedErrors.size());
+    }
+
+    @Test
+    public void streamedListObjects_consumerInvocationCount() throws Exception {
+        // Given
+        int expectedCount = 100;
+        List<String> lines = new ArrayList<>();
+        for (int i = 0; i < expectedCount; i++) {
+            lines.add(String.format("{\"result\":{\"object\":\"document:%d\"}}", i));
+        }
+        Stream<String> streamResponse = lines.stream();
+
+        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+                CompletableFuture.completedFuture(mockResponse);
+
+        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+
+        AtomicInteger callCount = new AtomicInteger(0);
+        ClientListObjectsRequest request = new ClientListObjectsRequest()
+                .type(DEFAULT_TYPE)
+                .relation(DEFAULT_RELATION)
+                .user(DEFAULT_USER);
+
+        // When
+        CompletableFuture<Void> future = fga.streamedListObjects(request, response -> callCount.incrementAndGet());
+        future.get(); // Wait for completion
+
+        // Then
+        assertEquals(expectedCount, callCount.get());
+    }
+
+    @Test
+    public void streamedListObjects_chainingWithOtherOperations() throws Exception {
+        // Given
+        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
+        Stream<String> streamResponse = Stream.of(line1);
+
+        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+                CompletableFuture.completedFuture(mockResponse);
+
+        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+
+        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+        ClientListObjectsRequest request = new ClientListObjectsRequest()
+                .type(DEFAULT_TYPE)
+                .relation(DEFAULT_RELATION)
+                .user(DEFAULT_USER);
+
+        // When - Chain with other async operations
+        AtomicInteger completionFlag = new AtomicInteger(0);
+        CompletableFuture<Void> future = fga.streamedListObjects(request, receivedObjects::add)
+                .thenRun(() -> completionFlag.set(1))
+                .thenRun(() -> completionFlag.set(2));
+
+        future.get(); // Wait for all chained operations
+
+        // Then
+        assertEquals(1, receivedObjects.size());
+        assertEquals(2, completionFlag.get());
+    }
+
+    @Test
+    public void streamedListObjects_additionalHeadersPassedThrough() throws Exception {
+        // Given
+        String line1 = "{\"result\":{\"object\":\"document:1\"}}";
+        Stream<String> streamResponse = Stream.of(line1);
+
+        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(200, streamResponse);
+        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+                CompletableFuture.completedFuture(mockResponse);
+
+        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+
+        List<StreamedListObjectsResponse> receivedObjects = new ArrayList<>();
+        ClientListObjectsRequest request = new ClientListObjectsRequest()
+                .type(DEFAULT_TYPE)
+                .relation(DEFAULT_RELATION)
+                .user(DEFAULT_USER);
+
+        // Create options with additional headers
+        Map<String, String> additionalHeaders = Map.of(
+                "X-Custom-Header", "custom-value",
+                "X-Request-ID", "test-request-123");
+
+        ClientStreamedListObjectsOptions options =
+                new ClientStreamedListObjectsOptions().additionalHeaders(additionalHeaders);
+
+        // When
+        CompletableFuture<Void> future = fga.streamedListObjects(request, options, receivedObjects::add);
+        future.get(); // Wait for completion
+
+        // Then
+        assertEquals(1, receivedObjects.size());
+        assertEquals("document:1", receivedObjects.get(0).getObject());
+
+        // Verify that the HTTP client was called (which means headers were applied)
+        verify(mockHttpClient, times(1)).sendAsync(any(), any());
+    }
+
+    @Test
+    public void streamedListObjects_preservesApiExceptionType() throws Exception {
+        // Given - HTTP 400 error should create ApiException
+        Stream<String> streamResponse = Stream.empty();
+        HttpResponse<Stream<String>> mockResponse = createMockStreamResponse(400, streamResponse);
+        CompletableFuture<HttpResponse<Stream<String>>> responseFuture =
+                CompletableFuture.completedFuture(mockResponse);
+
+        when(mockHttpClient.<Stream<String>>sendAsync(any(), any())).thenReturn(responseFuture);
+
+        List<Throwable> receivedErrors = new ArrayList<>();
+        ClientListObjectsRequest request = new ClientListObjectsRequest()
+                .type(DEFAULT_TYPE)
+                .relation(DEFAULT_RELATION)
+                .user(DEFAULT_USER);
+
+        // When
+        CompletableFuture<Void> future = fga.streamedListObjects(request, null, obj -> {}, receivedErrors::add);
+
+        try {
+            future.get();
+            fail("Expected exception");
+        } catch (Exception e) {
+            // Expected to fail
+        }
+
+        // Then - verify the error consumer received the original ApiException, not wrapped
+        assertEquals(1, receivedErrors.size());
+        Throwable error = receivedErrors.get(0);
+        assertTrue(
+                error instanceof dev.openfga.sdk.errors.ApiException,
+                "Expected ApiException but got " + error.getClass().getName());
+        dev.openfga.sdk.errors.ApiException apiException = (dev.openfga.sdk.errors.ApiException) error;
+        assertEquals(400, apiException.getStatusCode());
+    }
+
+    private HttpResponse<Stream<String>> createMockStreamResponse(int statusCode, Stream<String> body) {
+        HttpResponse<Stream<String>> mockResponse = mock(HttpResponse.class);
+        when(mockResponse.statusCode()).thenReturn(statusCode);
+        when(mockResponse.body()).thenReturn(body);
+
+        // Create mock headers
+        HttpHeaders mockHeaders = mock(HttpHeaders.class);
+        when(mockHeaders.map()).thenReturn(Map.of("content-type", List.of("application/json")));
+        when(mockResponse.headers()).thenReturn(mockHeaders);
+
+        return mockResponse;
+    }
+}