feat: update comm

Author: SoulPancake

src/main/java/dev/openfga/sdk/api/BaseStreamingApi.java

@@ -29,9 +29,9 @@
 import java.util.stream.Stream;
 
 /**
- * Base class for handling streaming API responses using NDJSON format.
+ * Base class for handling streaming API responses.
  * This class provides generic streaming functionality that can be reused across
- * different streaming endpoints by handling the common NDJSON parsing and error handling logic.
+ * different streaming endpoints by handling the common streaming parsing and error handling logic.
  *
  * @param <T> The type of response objects in the stream
  */
@@ -57,7 +57,7 @@ protected BaseStreamingApi(
     }
 
     /**
-     * Process a streaming NDJSON response asynchronously.
+     * Process a streaming response asynchronously.
      * Each line in the response is parsed and delivered to the consumer callback.
      *
      * @param request The HTTP request to execute
@@ -69,7 +69,7 @@ protected CompletableFuture<Void> processStreamingResponse(
             HttpRequest request, Consumer<T> consumer, Consumer<Throwable> errorConsumer) {
 
         // Use async HTTP client with streaming body handler
-        // ofLines() provides line-by-line streaming which is perfect for NDJSON
+        // ofLines() provides line-by-line streaming
         return apiClient
                 .getHttpClient()
                 .sendAsync(request, HttpResponse.BodyHandlers.ofLines())
@@ -117,7 +117,7 @@ protected CompletableFuture<Void> processStreamingResponse(
     }
 
     /**
-     * Process a single line from the NDJSON stream
+     * Process a single line from the stream
      *
      * @param line The JSON line to process
      * @param consumer Callback to handle the parsed result

src/main/java/dev/openfga/sdk/api/model/StreamResult.java

@@ -19,7 +19,7 @@
 
 /**
  * Generic wrapper for streaming results that can contain either a result or an error.
- * This class is used to deserialize NDJSON streaming responses where each line may contain
+ * This class is used to deserialize streaming responses where each line may contain
  * either a successful result or an error status.
  *
  * @param <T> The type of the result object

src/test/java/dev/openfga/sdk/api/StreamingApiTest.java

@@ -29,7 +29,7 @@
 /**
  * Test class demonstrating the generic streaming implementation.
  * This test shows how the BaseStreamingApi provides reusable functionality
- * for any streaming endpoint that returns NDJSON format.
+ * for any streaming endpoint that returns line-delimited JSON format.
  */
 class StreamingApiTest {
 
@@ -66,12 +66,12 @@ void setUp() {
 
     @Test
     void testStreamedListObjects_successfulStream() throws Exception {
-        // Arrange: Create NDJSON response with multiple objects
-        String ndjsonResponse = "{\"result\":{\"object\":\"document:1\"}}\n"
+        // Arrange: Create  response with multiple objects
+        String Response = "{\"result\":{\"object\":\"document:1\"}}\n"
                 + "{\"result\":{\"object\":\"document:2\"}}\n"
                 + "{\"result\":{\"object\":\"document:3\"}}\n";
 
-        Stream<String> lineStream = ndjsonResponse.lines();
+        Stream<String> lineStream = Response.lines();
         when(mockHttpResponse.body()).thenReturn(lineStream);
         when(mockHttpResponse.statusCode()).thenReturn(200);
 
@@ -102,11 +102,11 @@ void testStreamedListObjects_successfulStream() throws Exception {
 
     @Test
     void testStreamedListObjects_withErrorInStream() throws Exception {
-        // Arrange: NDJSON with an error
-        String ndjsonResponse = "{\"result\":{\"object\":\"document:1\"}}\n"
+        // Arrange: Streaming response with an error
+        String Response = "{\"result\":{\"object\":\"document:1\"}}\n"
                 + "{\"error\":{\"code\":400,\"message\":\"Something went wrong\"}}\n";
 
-        Stream<String> lineStream = ndjsonResponse.lines();
+        Stream<String> lineStream = Response.lines();
         when(mockHttpResponse.body()).thenReturn(lineStream);
         when(mockHttpResponse.statusCode()).thenReturn(200);
 
@@ -168,10 +168,10 @@ void testStreamedListObjects_httpError() throws Exception {
 
     @Test
     void testStreamedListObjects_emptyStream() throws Exception {
-        // Arrange: Empty NDJSON response
-        String ndjsonResponse = "";
+        // Arrange: Empty streaming response
+        String streamResponse = "";
 
-        Stream<String> lineStream = ndjsonResponse.lines();
+        Stream<String> lineStream = streamResponse.lines();
         when(mockHttpResponse.body()).thenReturn(lineStream);
         when(mockHttpResponse.statusCode()).thenReturn(200);
 
@@ -194,17 +194,17 @@ void testStreamedListObjects_emptyStream() throws Exception {
 
     @Test
     void testStreamedListObjects_largeStream() throws Exception {
-        // Arrange: Large NDJSON response with many objects
-        StringBuilder ndjsonBuilder = new StringBuilder();
+        // Arrange: Large streaming response with many objects
+        StringBuilder streamBuilder = new StringBuilder();
         int objectCount = 1000;
         for (int i = 0; i < objectCount; i++) {
-            ndjsonBuilder
+            streamBuilder
                     .append("{\"result\":{\"object\":\"document:")
                     .append(i)
                     .append("\"}}\n");
         }
 
-        Stream<String> lineStream = ndjsonBuilder.toString().lines();
+        Stream<String> lineStream = streamBuilder.toString().lines();
         when(mockHttpResponse.body()).thenReturn(lineStream);
         when(mockHttpResponse.statusCode()).thenReturn(200);