Revert "chore: make streamed list objects client layer pvt (#266)"

SoulPancake · web-flow · commit 3f4ac5deb20d · 2026-01-09T21:08:18.000+05:30
This reverts commit 7e9a960.
diff --git a/examples/streamed-list-objects/README.md b/examples/streamed-list-objects/README.md
@@ -1,8 +1,5 @@
 # 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
@@ -1,7 +1,3 @@
-// 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;
@@ -196,4 +192,3 @@ 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
@@ -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
      */
-    CompletableFuture<Void> streamedListObjects(
+    public CompletableFuture<Void> streamedListObjects(
             ClientListObjectsRequest request, Consumer<StreamedListObjectsResponse> consumer)
             throws FgaInvalidParameterException {
         if (consumer == null) {
@@ -1171,7 +1171,7 @@ 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
      */
-    CompletableFuture<Void> streamedListObjects(
+    public CompletableFuture<Void> streamedListObjects(
             ClientListObjectsRequest request,
             ClientStreamedListObjectsOptions options,
             Consumer<StreamedListObjectsResponse> consumer)
@@ -1211,7 +1211,7 @@ 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
      */
-    CompletableFuture<Void> streamedListObjects(
+    public 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
@@ -14,7 +14,6 @@
 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;
@@ -375,7 +374,6 @@ private String writeAuthModel(String storeId) throws Exception {
     }
 
     @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());
diff --git a/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java b/src/test/java/dev/openfga/sdk/api/client/StreamedListObjectsTest.java
@@ -24,11 +24,9 @@
 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";

Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,3 @@`
`1`		`-// NOTE: This example is temporarily commented out as the streamedListObjects API is not yet available for public use.`
`2`		`-// It will be enabled in a future release.`
`3`		`-`
`4`		`-/*`
`5`	`1`	`package dev.openfga.sdk.example;`
`6`	`2`
`7`	`3`	`import com.fasterxml.jackson.databind.ObjectMapper;`
`@@ -196,4 +192,3 @@ private WriteAuthorizationModelRequest createAuthorizationModel() {`
`196`	`192`	`}`
`197`	`193`	`}`
`198`	`194`	`}`
`199`		`-*/`