Package org.bsc.langgraph4j.langchain4j.generators

Class StreamingChatGenerator<State extends AgentState>

java.lang.Object

org.bsc.langgraph4j.langchain4j.generators.StreamingChatGenerator<State>

All Implemented Interfaces:

Iterable<StreamingOutput<State>>, org.bsc.async.AsyncGenerator<StreamingOutput<State>>, org.bsc.async.AsyncGenerator.HasResultValue, LG4JLoggable

public class StreamingChatGenerator<State extends AgentState>
extends Object
implements org.bsc.async.AsyncGenerator<StreamingOutput<State>>, org.bsc.async.AsyncGenerator.HasResultValue, LG4JLoggable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamingChatGenerator.Builder<State extends AgentState>	Builder class for constructing instances of LLMStreamingGenerator.

Nested classes/interfaces inherited from interface org.bsc.async.AsyncGenerator

org.bsc.async.AsyncGenerator.Base<E>, org.bsc.async.AsyncGenerator.BaseCancellable<E>, org.bsc.async.AsyncGenerator.Cancellable<E>, org.bsc.async.AsyncGenerator.Data<E>, org.bsc.async.AsyncGenerator.Embed<E>, org.bsc.async.AsyncGenerator.EmbedCompletionHandler, org.bsc.async.AsyncGenerator.HasResultValue, org.bsc.async.AsyncGenerator.IsCancellable, org.bsc.async.AsyncGenerator.ReduceResult<E>, org.bsc.async.AsyncGenerator.WithEmbed<E>, org.bsc.async.AsyncGenerator.WithResult<E>

Field Summary

Fields inherited from interface org.bsc.langgraph4j.LG4JLoggable

log

Method Summary

Modifier and Type	Method	Description
static <State extends AgentState> StreamingChatGenerator.Builder<State>	builder()	Creates a new Builder instance for LLMStreamingGenerator.
final Executor	executor()
dev.langchain4j.model.chat.response.StreamingChatResponseHandler	handler()	Returns the StreamingResponseHandler associated with this generator.
final org.bsc.async.AsyncGenerator.Data<StreamingOutput<State>>	next()
final Optional<Object>	resultValue()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.bsc.async.AsyncGenerator

flatMap, forEachAsync, iterator, map, reduce, reduce, reduceAsync, reduceAsync, stream, toCompletableFuture, toCompletableFutureAsync

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Method Details

builder

public static <State extends AgentState>
StreamingChatGenerator.Builder<State> builder()

Creates a new Builder instance for LLMStreamingGenerator.

Type Parameters:

State - the type of the state extending AgentState

Returns:

a new Builder instance

next

public final org.bsc.async.AsyncGenerator.Data<StreamingOutput<State>> next()

Specified by:

next in interface org.bsc.async.AsyncGenerator<State extends AgentState>

executor

public final Executor executor()

Specified by:

executor in interface org.bsc.async.AsyncGenerator<State extends AgentState>

resultValue

public final Optional<Object> resultValue()

Specified by:

resultValue in interface org.bsc.async.AsyncGenerator.HasResultValue

handler

public dev.langchain4j.model.chat.response.StreamingChatResponseHandler handler()

Returns the StreamingResponseHandler associated with this generator.

Returns:

the handler for streaming responses