Package org.bsc.langgraph4j.langchain4j.generators

Class StreamingChatGenerator<State extends AgentState>

java.lang.Object
org.bsc.async.AsyncGenerator.Base<E>
org.bsc.async.AsyncGenerator.BaseCancellable<E>
org.bsc.async.AsyncGenerator.WithResult<StreamingOutput<State>>
org.bsc.langgraph4j.langchain4j.generators.StreamingChatGenerator<State>
All Implemented Interfaces:
AutoCloseable, Iterable<StreamingOutput<State>>, org.bsc.async.AsyncGenerator<StreamingOutput<State>>, org.bsc.async.AsyncGenerator.Cancellable<StreamingOutput<State>>, org.bsc.async.AsyncGenerator.HasResultValue, org.bsc.async.AsyncGenerator.IsCancellable
public class StreamingChatGenerator<State extends AgentState> extends org.bsc.async.AsyncGenerator.WithResult<StreamingOutput<State>>

  • 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 extends Object>, org.bsc.async.AsyncGenerator.BaseCancellable<E extends Object>, org.bsc.async.AsyncGenerator.Cancellable<E extends Object>, org.bsc.async.AsyncGenerator.Data<E extends Object>, org.bsc.async.AsyncGenerator.Embed<E extends Object>, org.bsc.async.AsyncGenerator.EmbedCompletionHandler, org.bsc.async.AsyncGenerator.HasResultValue, org.bsc.async.AsyncGenerator.IsCancellable, org.bsc.async.AsyncGenerator.WithEmbed<E extends Object>, org.bsc.async.AsyncGenerator.WithResult<E extends Object>

  • Field Summary

    Fields inherited from class org.bsc.async.AsyncGenerator.WithResult

    delegate

    Fields inherited from interface org.bsc.async.AsyncGenerator.IsCancellable

    CANCELLED

  • Method Summary

    Modifier and Type
    Method
    Description
    static <State extends AgentState>
    StreamingChatGenerator.Builder<State>
    builder()
    Creates a new Builder instance for LLMStreamingGenerator.
    dev.langchain4j.model.chat.response.StreamingChatResponseHandler
    handler()
    Returns the StreamingResponseHandler associated with this generator.

    Methods inherited from class org.bsc.async.AsyncGenerator.WithResult

    cancel, delegate, executor, next, resultValue

    Methods inherited from class org.bsc.async.AsyncGenerator.BaseCancellable

    isCancelled

    Methods inherited from class org.bsc.async.AsyncGenerator.Base

    close, isClosed

    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, 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

    • handler

      public dev.langchain4j.model.chat.response.StreamingChatResponseHandler handler()
      Returns the StreamingResponseHandler associated with this generator.
      Returns:
      the handler for streaming responses