docs: add stream cancellation example

Author: TomerAberbach

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

@@ -0,0 +1,41 @@
+package com.openai.example;
+
+import com.openai.client.OpenAIClientAsync;
+import com.openai.client.okhttp.OpenAIOkHttpClientAsync;
+import com.openai.core.http.AsyncStreamResponse;
+import com.openai.models.ChatCompletionChunk;
+import com.openai.models.ChatCompletionCreateParams;
+import com.openai.models.ChatModel;
+
+public final class CompletionsStreamingCancellationAsyncExample {
+    private CompletionsStreamingCancellationAsyncExample() {}
+
+    public static void main(String[] args) {
+        // Configures using one of:
+        // - The `OPENAI_API_KEY` environment variable
+        // - The `AZURE_OPENAI_ENDPOINT` and `AZURE_OPENAI_KEY` environment variables
+        OpenAIClientAsync client = OpenAIOkHttpClientAsync.fromEnv();
+
+        ChatCompletionCreateParams createParams = ChatCompletionCreateParams.builder()
+                .model(ChatModel.GPT_3_5_TURBO)
+                .maxCompletionTokens(2048)
+                .addDeveloperMessage("Make sure you mention Stainless!")
+                .addUserMessage("Tell me a story about building the best SDK!")
+                .build();
+
+        AsyncStreamResponse<ChatCompletionChunk> streamResponse =
+                client.chat().completions().createStreaming(createParams);
+        streamResponse
+                .subscribe(completion -> completion.choices().stream()
+                        .flatMap(choice -> choice.delta().content().stream())
+                        .forEach(text -> {
+                            System.out.print(text);
+                            if (text.contains("SDK")) {
+                                // Close the stream early.
+                                streamResponse.close();
+                            }
+                        }))
+                .onCompleteFuture()
+                .join();
+    }
+}

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

@@ -0,0 +1,40 @@
+package com.openai.example;
+
+import com.openai.client.OpenAIClient;
+import com.openai.client.okhttp.OpenAIOkHttpClient;
+import com.openai.core.http.StreamResponse;
+import com.openai.models.ChatCompletionChunk;
+import com.openai.models.ChatCompletionCreateParams;
+import com.openai.models.ChatModel;
+
+public final class CompletionsStreamingCancellationExample {
+    private CompletionsStreamingCancellationExample() {}
+
+    public static void main(String[] args) {
+        // Configures using one of:
+        // - The `OPENAI_API_KEY` environment variable
+        // - The `AZURE_OPENAI_ENDPOINT` and `AZURE_OPENAI_KEY` environment variables
+        OpenAIClient client = OpenAIOkHttpClient.fromEnv();
+
+        ChatCompletionCreateParams createParams = ChatCompletionCreateParams.builder()
+                .model(ChatModel.GPT_3_5_TURBO)
+                .maxCompletionTokens(2048)
+                .addDeveloperMessage("Make sure you mention Stainless!")
+                .addUserMessage("Tell me a story about building the best SDK!")
+                .build();
+
+        try (StreamResponse<ChatCompletionChunk> streamResponse =
+                client.chat().completions().createStreaming(createParams)) {
+            streamResponse.stream()
+                    .flatMap(completion -> completion.choices().stream())
+                    .flatMap(choice -> choice.delta().content().stream())
+                    .forEach(text -> {
+                        System.out.print(text);
+                        if (text.contains("SDK")) {
+                            // Close the stream early.
+                            streamResponse.close();
+                        }
+                    });
+        }
+    }
+}