Package org.bsc.langgraph4j.spring.ai.generators

Class StreamingChatGenerator.Builder<State extends AgentState>

java.lang.Object

org.bsc.langgraph4j.spring.ai.generators.StreamingChatGenerator.Builder<State>

Enclosing class:

StreamingChatGenerator<State extends AgentState>

public static class StreamingChatGenerator.Builder<State extends AgentState>
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
org.bsc.async.AsyncGenerator<? extends NodeOutput<State>>	build(reactor.core.publisher.Flux<org.springframework.ai.chat.model.ChatResponse> flux)	Builds and returns an instance of LLMStreamingGenerator.
StreamingChatGenerator.Builder<State>	emitStreamingOutputEnd(boolean emitStreamingOutputEnd)
StreamingChatGenerator.Builder<State>	mapResult(Function<org.springframework.ai.chat.model.ChatResponse,Map<String,Object>> mapResult)	Sets the mapping function for the builder.
StreamingChatGenerator.Builder<State>	startingNode(String node)	Sets the starting node for the builder.
StreamingChatGenerator.Builder<State>	startingState(State state)	Sets the starting state for the builder.

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

emitStreamingOutputEnd

public StreamingChatGenerator.Builder<State> emitStreamingOutputEnd(boolean emitStreamingOutputEnd)

mapResult

public StreamingChatGenerator.Builder<State> mapResult(Function<org.springframework.ai.chat.model.ChatResponse,Map<String,Object>> mapResult)

Sets the mapping function for the builder.

Parameters:

mapResult - a function to map the response to a result

Returns:

the builder instance

startingNode

public StreamingChatGenerator.Builder<State> startingNode(String node)

Sets the starting node for the builder.

Parameters:

node - the starting node

Returns:

the builder instance

startingState

public StreamingChatGenerator.Builder<State> startingState(State state)

Sets the starting state for the builder.

Parameters:

state - the initial state

Returns:

the builder instance

build

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

Builds and returns an instance of LLMStreamingGenerator.

Returns:

a new instance of LLMStreamingGenerator