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

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)
reactor.core.publisher.Flux<AdvisedResponse>	aggregateAdvisedResponse(reactor.core.publisher.Flux<AdvisedResponse> advisedResponses, Consumer<AdvisedResponse> aggregationHandler)

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

aggregateAdvisedResponse

public reactor.core.publisher.Flux<AdvisedResponse> aggregateAdvisedResponse(reactor.core.publisher.Flux<AdvisedResponse> advisedResponses,
 Consumer<AdvisedResponse> aggregationHandler)

aggregate

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