Package org.springframework.ai.chat.client

Class ChatClientMessageAggregator

java.lang.Object

org.springframework.ai.chat.client.ChatClientMessageAggregator

public class ChatClientMessageAggregator
extends Object

Helper that for streaming chat responses, aggregate the chat response messages into a single AssistantMessage. Job is performed in parallel to the chat response processing.

Since:

1.0.0

Author:

Christian Tzolov, Alexandros Pappas, Thomas Vitale

Constructor Summary

Constructors

Constructor	Description
ChatClientMessageAggregator()

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<ChatClientResponse>	aggregateChatClientResponse(reactor.core.publisher.Flux<ChatClientResponse> chatClientResponses, Consumer<ChatClientResponse> aggregationHandler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ChatClientMessageAggregator

public ChatClientMessageAggregator()

Method Details

aggregateChatClientResponse

public reactor.core.publisher.Flux<ChatClientResponse> aggregateChatClientResponse(reactor.core.publisher.Flux<ChatClientResponse> chatClientResponses,
 Consumer<ChatClientResponse> aggregationHandler)