diff --git a/models/spring-ai-azure-openai/src/main/java/org/springframework/ai/azure/openai/AzureOpenAiChatModel.java b/models/spring-ai-azure-openai/src/main/java/org/springframework/ai/azure/openai/AzureOpenAiChatModel.java index 9ac782f6c65..a83181e9409 100644 --- a/models/spring-ai-azure-openai/src/main/java/org/springframework/ai/azure/openai/AzureOpenAiChatModel.java +++ b/models/spring-ai-azure-openai/src/main/java/org/springframework/ai/azure/openai/AzureOpenAiChatModel.java @@ -185,11 +185,7 @@ public Flux stream(Prompt prompt) { } return !isFunctionCall.get(); }) - .concatMapIterable(window -> { - final var reduce = window.reduce(MergeUtils.emptyChatCompletions(), MergeUtils::mergeChatCompletions); - return List.of(reduce); - }) - .flatMap(mono -> mono); + .flatMap(window -> window); return accessibleChatCompletionsFlux .switchMap(accessibleChatCompletions -> handleFunctionCallOrReturnStream(options, Flux.just(accessibleChatCompletions)))