Fixes from review

Author: johnoliver

aiservices/google/src/main/java/com/microsoft/semantickernel/aiservices/google/chatcompletion/GeminiChatCompletion.java

@@ -16,6 +16,7 @@
 import com.google.protobuf.Value;
 import com.microsoft.semantickernel.Kernel;
 import com.microsoft.semantickernel.aiservices.google.GeminiService;
+import com.microsoft.semantickernel.aiservices.google.GeminiServiceBuilder;
 import com.microsoft.semantickernel.aiservices.google.implementation.MonoConverter;
 import com.microsoft.semantickernel.contextvariables.ContextVariableTypes;
 import com.microsoft.semantickernel.exceptions.AIException;
@@ -36,15 +37,14 @@
 import com.microsoft.semantickernel.services.chatcompletion.ChatCompletionService;
 import com.microsoft.semantickernel.services.chatcompletion.ChatHistory;
 import com.microsoft.semantickernel.services.chatcompletion.ChatMessageContent;
-import com.microsoft.semantickernel.aiservices.google.GeminiServiceBuilder;
+import com.microsoft.semantickernel.services.chatcompletion.StreamingChatContent;
 import java.io.IOException;
 import java.time.OffsetDateTime;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
 import java.util.stream.Collectors;
 import javax.annotation.Nullable;
-import com.microsoft.semantickernel.services.chatcompletion.StreamingChatContent;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import reactor.core.publisher.Flux;
@@ -78,17 +78,49 @@ public Mono<List<ChatMessageContent<?>>> getChatMessageContentsAsync(String prom
 
     @Override
     public Flux<StreamingChatContent<?>> getStreamingChatMessageContentsAsync(
-        ChatHistory chatHistory, @Nullable Kernel kernel,
+        ChatHistory chatHistory,
+        @Nullable Kernel kernel,
         @Nullable InvocationContext invocationContext) {
-        throw new UnsupportedOperationException(
-            "Streaming chat message contents are not supported");
+
+        LOGGER.warn("Streaming has been called on GeminiChatCompletion service. "
+            + "This is currently not supported in Gemini. "
+            + "The results will be returned in a non streaming fashion.");
+
+        return getChatMessageContentsAsync(chatHistory, kernel, invocationContext)
+            .flatMapIterable(chatMessageContents -> chatMessageContents)
+            .map(content -> {
+                return new GeminiStreamingChatMessageContent(
+                    content.getAuthorRole(),
+                    content.getContent(),
+                    getModelId(),
+                    content.getInnerContent(),
+                    content.getEncoding(),
+                    content.getMetadata(),
+                    null,
+                    UUID.randomUUID().toString());
+            });
     }
 
     @Override
     public Flux<StreamingChatContent<?>> getStreamingChatMessageContentsAsync(String prompt,
         @Nullable Kernel kernel, @Nullable InvocationContext invocationContext) {
-        throw new UnsupportedOperationException(
-            "Streaming chat message contents are not supported");
+        LOGGER.warn("Streaming has been called on GeminiChatCompletion service. "
+            + "This is currently not supported in Gemini. "
+            + "The results will be returned in a non streaming fashion.");
+
+        return getChatMessageContentsAsync(prompt, kernel, invocationContext)
+            .flatMapIterable(chatMessageContents -> chatMessageContents)
+            .map(content -> {
+                return new GeminiStreamingChatMessageContent(
+                    content.getAuthorRole(),
+                    content.getContent(),
+                    getModelId(),
+                    content.getInnerContent(),
+                    content.getEncoding(),
+                    content.getMetadata(),
+                    null,
+                    UUID.randomUUID().toString());
+            });
     }
 
     @Override

aiservices/google/src/main/java/com/microsoft/semantickernel/aiservices/google/chatcompletion/GeminiStreamingChatMessageContent.java

@@ -0,0 +1,45 @@
+// Copyright (c) Microsoft. All rights reserved.
+package com.microsoft.semantickernel.aiservices.google.chatcompletion;
+
+import com.microsoft.semantickernel.orchestration.FunctionResultMetadata;
+import com.microsoft.semantickernel.services.chatcompletion.AuthorRole;
+import com.microsoft.semantickernel.services.chatcompletion.StreamingChatContent;
+import java.nio.charset.Charset;
+import java.util.List;
+import javax.annotation.Nullable;
+
+/**
+ * Represents the content of a chat message.
+ *
+ * @param <T> The type of the inner content.
+ */
+public class GeminiStreamingChatMessageContent<T> extends GeminiChatMessageContent<T> implements
+    StreamingChatContent<T> {
+
+    private final String id;
+
+    /**
+     * Creates a new instance of the {@link GeminiChatMessageContent} class.
+     *
+     * @param authorRole          The author role that generated the content.
+     * @param content             The content.
+     * @param modelId             The model id.
+     * @param innerContent        The inner content.
+     * @param encoding            The encoding.
+     * @param metadata            The metadata.
+     * @param geminiFunctionCalls The function calls.
+     */
+    public GeminiStreamingChatMessageContent(AuthorRole authorRole, String content,
+        @Nullable String modelId, @Nullable T innerContent, @Nullable Charset encoding,
+        @Nullable FunctionResultMetadata metadata,
+        @Nullable List<GeminiFunctionCall> geminiFunctionCalls,
+        String id) {
+        super(authorRole, content, modelId, innerContent, encoding, metadata, geminiFunctionCalls);
+        this.id = id;
+    }
+
+    @Override
+    public String getId() {
+        return id;
+    }
+}