chore(internal): fix custom code

Author: stainless-app[bot]

openai-java-example/src/main/java/com/openai/example/AssistantAsyncExample.java

@@ -109,18 +109,14 @@ private static CompletableFuture<Void> listThreadMessages(OpenAIClientAsync clie
                         .order(MessageListParams.Order.ASC)
                         .build());
         return pageFuture.thenComposeAsync(page -> page.autoPager()
-                .forEach(
-                        currentMessage -> {
-                            System.out.println(currentMessage.role().toString().toUpperCase());
-                            currentMessage.content().stream()
-                                    .flatMap(content -> content.text().stream())
-                                    .forEach(textBlock ->
-                                            System.out.println(textBlock.text().value()));
-                            System.out.println();
-
-                            // Keep iterating
-                            return true;
-                        },
-                        pageFuture.defaultExecutor()));
+                .subscribe(currentMessage -> {
+                    System.out.println(currentMessage.role().toString().toUpperCase());
+                    currentMessage.content().stream()
+                            .flatMap(content -> content.text().stream())
+                            .forEach(textBlock ->
+                                    System.out.println(textBlock.text().value()));
+                    System.out.println();
+                })
+                .onCompleteFuture());
     }
 }

openai-java-example/src/main/java/com/openai/example/ModelListAsyncExample.java

@@ -17,13 +17,8 @@ public static void main(String[] args) {
         CompletableFuture<ModelListPageAsync> pageFuture = client.models().list();
         pageFuture
                 .thenComposeAsync(page -> page.autoPager()
-                        .forEach(
-                                model -> {
-                                    System.out.println(model.id());
-                                    // Keep iterating
-                                    return true;
-                                },
-                                pageFuture.defaultExecutor()))
+                        .subscribe(model -> System.out.println(model.id()))
+                        .onCompleteFuture())
                 .join();
     }
 }