Package org.springframework.ai.chat.model

Class MessageAggregator

java.lang.Object

org.springframework.ai.chat.model.MessageAggregator

public class MessageAggregator
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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	MessageAggregator.DefaultUsage

Constructor Summary

Constructors

Constructor	Description
MessageAggregator()

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<ChatResponse>	aggregate(reactor.core.publisher.Flux<ChatResponse> fluxChatResponse, Consumer<ChatResponse> onAggregationComplete)

Methods inherited from class java.lang.Object

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

Constructor Details

MessageAggregator

public MessageAggregator()

Method Details

aggregate

public reactor.core.publisher.Flux<ChatResponse> aggregate(reactor.core.publisher.Flux<ChatResponse> fluxChatResponse,
 Consumer<ChatResponse> onAggregationComplete)