Package com.alibaba.cloud.ai.util

Class StreamingChatGeneratorUtil.StreamingProcessorBuilder

java.lang.Object

com.alibaba.cloud.ai.util.StreamingChatGeneratorUtil.StreamingProcessorBuilder

Enclosing class:

StreamingChatGeneratorUtil

public static class StreamingChatGeneratorUtil.StreamingProcessorBuilder
extends Object

Method Summary

Modifier and Type	Method	Description
AsyncGenerator<? extends NodeOutput>	build(reactor.core.publisher.Flux<org.springframework.ai.chat.model.ChatResponse> sourceFlux)	Build streaming processor
StreamingChatGeneratorUtil.StreamingProcessorBuilder	businessLogicExecutor(Function<OverAllState,Map<String,Object>> businessLogicExecutor)	Set business logic executor (used to execute business logic in mapResult)
StreamingChatGeneratorUtil.StreamingProcessorBuilder	completionMessage(String completionMessage)
StreamingChatGeneratorUtil.StreamingProcessorBuilder	contentExtractor(Function<org.springframework.ai.chat.model.ChatResponse,String> contentExtractor)
StreamingChatGeneratorUtil.StreamingProcessorBuilder	nodeClass(Class<?> nodeClass)	Set node class (automatically extract class name as node name)
StreamingChatGeneratorUtil.StreamingProcessorBuilder	nodeName(String nodeName)	Set node name
StreamingChatGeneratorUtil.StreamingProcessorBuilder	resultMapper(Function<String,Map<String,Object>> resultMapper)	Set result mapping function (convert collected content to final returned Map)
StreamingChatGeneratorUtil.StreamingProcessorBuilder	startMessage(String startMessage)
StreamingChatGeneratorUtil.StreamingProcessorBuilder	state(OverAllState state)	Set state
StreamingChatGeneratorUtil.StreamingProcessorBuilder	trimResult(boolean trimResult)	Set whether to trim the final result
StreamingChatGeneratorUtil.StreamingProcessorBuilder	type(StreamResponseType type)

Methods inherited from class java.lang.Object

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

Method Details

startMessage

public StreamingChatGeneratorUtil.StreamingProcessorBuilder startMessage(String startMessage)

completionMessage

public StreamingChatGeneratorUtil.StreamingProcessorBuilder completionMessage(String completionMessage)

type

public StreamingChatGeneratorUtil.StreamingProcessorBuilder type(StreamResponseType type)

contentExtractor

public StreamingChatGeneratorUtil.StreamingProcessorBuilder contentExtractor(Function<org.springframework.ai.chat.model.ChatResponse,String> contentExtractor)

nodeName

public StreamingChatGeneratorUtil.StreamingProcessorBuilder nodeName(String nodeName)

Set node name

nodeClass

public StreamingChatGeneratorUtil.StreamingProcessorBuilder nodeClass(Class<?> nodeClass)

Set node class (automatically extract class name as node name)

state

public StreamingChatGeneratorUtil.StreamingProcessorBuilder state(OverAllState state)

Set state

resultMapper

public StreamingChatGeneratorUtil.StreamingProcessorBuilder resultMapper(Function<String,Map<String,Object>> resultMapper)

Set result mapping function (convert collected content to final returned Map)

trimResult

public StreamingChatGeneratorUtil.StreamingProcessorBuilder trimResult(boolean trimResult)

Set whether to trim the final result

businessLogicExecutor

public StreamingChatGeneratorUtil.StreamingProcessorBuilder businessLogicExecutor(Function<OverAllState,Map<String,Object>> businessLogicExecutor)

Set business logic executor (used to execute business logic in mapResult)

build

public AsyncGenerator<? extends NodeOutput> build(reactor.core.publisher.Flux<org.springframework.ai.chat.model.ChatResponse> sourceFlux)

Build streaming processor

Parameters:

sourceFlux - source data stream

Returns:

AsyncGenerator instance