small updates (#140)

Azure · Dec 15, 2023 · 606bc37 · 606bc37
1 parent 8a3efa9
commit 606bc37
Show file tree

Hide file tree

Showing 6 changed files with 4 additions and 10 deletions.
diff --git a/...mplates/openai-chat-java-streaming/_.json → ...mplates/openai-chat-streaming-java/_.json b/...mplates/openai-chat-java-streaming/_.json → ...mplates/openai-chat-streaming-java/_.json
@@ -1,5 +1,5 @@
 {
-  "_Name": "OpenAI Chat Completions in Java",
+  "_Name": "OpenAI Chat Completions (Streaming) in Java",
   "_Language": "Java",
   "OPENAI_ENDPOINT": "<insert your OpenAI endpoint here>",
   "OPENAI_API_KEY": "<insert your OpenAI API key here>",

diff --git a/...plates/openai-chat-java-streaming/pom.xml → ...plates/openai-chat-streaming-java/pom.xml b/...plates/openai-chat-java-streaming/pom.xml → ...plates/openai-chat-streaming-java/pom.xml
diff --git a/...-streaming/scripts/1-copydependencies.bat → ...aming-java/scripts/1-copydependencies.bat b/...-streaming/scripts/1-copydependencies.bat → ...aming-java/scripts/1-copydependencies.bat
diff --git a/...chat-java-streaming/scripts/2-compile.bat → ...chat-streaming-java/scripts/2-compile.bat b/...chat-java-streaming/scripts/2-compile.bat → ...chat-streaming-java/scripts/2-compile.bat
diff --git a/...nai-chat-java-streaming/scripts/3-run.bat → ...nai-chat-streaming-java/scripts/3-run.bat b/...nai-chat-java-streaming/scripts/3-run.bat → ...nai-chat-streaming-java/scripts/3-run.bat
diff --git a/...eaming/src/OpenAIQuickstartStreaming.java → ...g-java/src/OpenAIQuickstartStreaming.java b/...eaming/src/OpenAIQuickstartStreaming.java → ...g-java/src/OpenAIQuickstartStreaming.java
@@ -70,7 +70,6 @@ public Flux<ChatCompletions> getChatCompletionsStreamingAsync(String userPrompt,
         Flux<ChatCompletions> response = client.getChatCompletionsStream(deploymentName, options);
 
         response.subscribe(chatResponse -> {
-            // Process each response as it comes in.
             if (chatResponse.getChoices() != null) {
                 for (ChatChoice update : chatResponse.getChoices()) {
                     if (update.getDelta() == null || update.getDelta().getContent() == null)
@@ -94,13 +93,9 @@ public Flux<ChatCompletions> getChatCompletionsStreamingAsync(String userPrompt,
 
                 options.getMessages().add(new ChatRequestAssistantMessage(responseContent.toString()));
             }
-        }, error -> {
-            // Error encountered
-        }, () -> {
-            // Stream completed
         });
 
-        return response; // response.toIterable();
+        return response;
     }
 
     public static void main(String[] args) {
@@ -113,13 +108,12 @@ public static void main(String[] args) {
             if (userPrompt.isEmpty() || "exit".equals(userPrompt))
                 break;
 
-            System.out.print("Assistant: ");
+            System.out.print("\nAssistant: ");
             Flux<ChatCompletions> responseFlux = chat.getChatCompletionsStreamingAsync(userPrompt, update -> {
                 System.out.print(update.getContent());
             });
-            // block until the last element is available
             responseFlux.blockLast(Duration.ofSeconds(20));
-            System.out.println("");
+            System.out.println("\n");
         }
         scanner.close();
     }