fix: fmt file

Author: SoulPancake

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

@@ -82,18 +82,13 @@ void testStreamedListObjects_successfulStream() throws Exception {
         List<String> receivedObjects = Collections.synchronizedList(new ArrayList<>());
         CountDownLatch latch = new CountDownLatch(3);
 
-        ListObjectsRequest request = new ListObjectsRequest()
-                .type("document")
-                .relation("viewer")
-                .user("user:anne");
+        ListObjectsRequest request =
+                new ListObjectsRequest().type("document").relation("viewer").user("user:anne");
 
-        CompletableFuture<Void> future = streamingApi.streamedListObjects(
-                "store123",
-                request,
-                response -> {
-                    receivedObjects.add(response.getObject());
-                    latch.countDown();
-                });
+        CompletableFuture<Void> future = streamingApi.streamedListObjects("store123", request, response -> {
+            receivedObjects.add(response.getObject());
+            latch.countDown();
+        });
 
         // Assert: Wait for completion and verify results
         assertTrue(latch.await(5, TimeUnit.SECONDS), "Should receive all objects");
@@ -123,16 +118,11 @@ void testStreamedListObjects_withErrorInStream() throws Exception {
         List<Throwable> receivedErrors = Collections.synchronizedList(new ArrayList<>());
         CountDownLatch latch = new CountDownLatch(1);
 
-        ListObjectsRequest request = new ListObjectsRequest()
-                .type("document")
-                .relation("viewer")
-                .user("user:anne");
+        ListObjectsRequest request =
+                new ListObjectsRequest().type("document").relation("viewer").user("user:anne");
 
         CompletableFuture<Void> future = streamingApi.streamedListObjects(
-                "store123",
-                request,
-                response -> receivedObjects.add(response.getObject()),
-                error -> {
+                "store123", request, response -> receivedObjects.add(response.getObject()), error -> {
                     receivedErrors.add(error);
                     latch.countDown();
                 });
@@ -151,9 +141,8 @@ void testStreamedListObjects_withErrorInStream() throws Exception {
     void testStreamedListObjects_httpError() throws Exception {
         // Arrange: HTTP error response
         when(mockHttpResponse.statusCode()).thenReturn(400);
-        when(mockHttpResponse.headers()).thenReturn(java.net.http.HttpHeaders.of(
-                Collections.emptyMap(),
-                (k, v) -> true));
+        when(mockHttpResponse.headers())
+                .thenReturn(java.net.http.HttpHeaders.of(Collections.emptyMap(), (k, v) -> true));
 
         when(mockHttpClient.sendAsync(any(HttpRequest.class), any(HttpResponse.BodyHandler.class)))
                 .thenReturn(CompletableFuture.completedFuture(mockHttpResponse));
@@ -162,10 +151,8 @@ void testStreamedListObjects_httpError() throws Exception {
         List<String> receivedObjects = Collections.synchronizedList(new ArrayList<>());
         AtomicBoolean errorReceived = new AtomicBoolean(false);
 
-        ListObjectsRequest request = new ListObjectsRequest()
-                .type("document")
-                .relation("viewer")
-                .user("user:anne");
+        ListObjectsRequest request =
+                new ListObjectsRequest().type("document").relation("viewer").user("user:anne");
 
         CompletableFuture<Void> future = streamingApi.streamedListObjects(
                 "store123",
@@ -194,15 +181,11 @@ void testStreamedListObjects_emptyStream() throws Exception {
         // Act: Stream with no results
         List<String> receivedObjects = Collections.synchronizedList(new ArrayList<>());
 
-        ListObjectsRequest request = new ListObjectsRequest()
-                .type("document")
-                .relation("viewer")
-                .user("user:anne");
+        ListObjectsRequest request =
+                new ListObjectsRequest().type("document").relation("viewer").user("user:anne");
 
         CompletableFuture<Void> future = streamingApi.streamedListObjects(
-                "store123",
-                request,
-                response -> receivedObjects.add(response.getObject()));
+                "store123", request, response -> receivedObjects.add(response.getObject()));
 
         // Assert: Should complete without errors
         future.join();
@@ -215,7 +198,10 @@ void testStreamedListObjects_largeStream() throws Exception {
         StringBuilder ndjsonBuilder = new StringBuilder();
         int objectCount = 1000;
         for (int i = 0; i < objectCount; i++) {
-            ndjsonBuilder.append("{\"result\":{\"object\":\"document:").append(i).append("\"}}\n");
+            ndjsonBuilder
+                    .append("{\"result\":{\"object\":\"document:")
+                    .append(i)
+                    .append("\"}}\n");
         }
 
         Stream<String> lineStream = ndjsonBuilder.toString().lines();
@@ -229,18 +215,13 @@ void testStreamedListObjects_largeStream() throws Exception {
         List<String> receivedObjects = Collections.synchronizedList(new ArrayList<>());
         CountDownLatch latch = new CountDownLatch(objectCount);
 
-        ListObjectsRequest request = new ListObjectsRequest()
-                .type("document")
-                .relation("viewer")
-                .user("user:anne");
+        ListObjectsRequest request =
+                new ListObjectsRequest().type("document").relation("viewer").user("user:anne");
 
-        CompletableFuture<Void> future = streamingApi.streamedListObjects(
-                "store123",
-                request,
-                response -> {
-                    receivedObjects.add(response.getObject());
-                    latch.countDown();
-                });
+        CompletableFuture<Void> future = streamingApi.streamedListObjects("store123", request, response -> {
+            receivedObjects.add(response.getObject());
+            latch.countDown();
+        });
 
         // Assert: Should handle large stream efficiently
         assertTrue(latch.await(10, TimeUnit.SECONDS), "Should receive all " + objectCount + " objects");
@@ -259,8 +240,8 @@ void testGenericStreamResult_deserialization() throws Exception {
         // Test with result
         String jsonWithResult = "{\"result\":{\"object\":\"document:1\"}}";
         var resultType = mapper.getTypeFactory()
-                .constructParametricType(dev.openfga.sdk.api.model.StreamResult.class,
-                        StreamedListObjectsResponse.class);
+                .constructParametricType(
+                        dev.openfga.sdk.api.model.StreamResult.class, StreamedListObjectsResponse.class);
 
         Object streamResult = mapper.readValue(jsonWithResult, resultType);
         assertNotNull(streamResult);
@@ -271,4 +252,3 @@ void testGenericStreamResult_deserialization() throws Exception {
         assertNotNull(streamResultWithError);
     }
 }
-