Class StreamingChatModelHelper

java.lang.Object

dev.langchain4j.model.chat.StreamingChatModelHelper

public final class StreamingChatModelHelper
extends Object

Bridges a single reactive StreamingChatModel.chat(ChatRequest) call to a CompletableFuture of its terminal ChatResponse: it subscribes with unbounded demand and completes the future with the last ChatResponse emitted by the stream. This lets callers that need the whole response (driving a tool loop, output-guardrail reprompts, ...) work with a streaming-only model without blocking.

Uses the reactive publisher API, not the handler-based chat(request, handler) overload. This is a raw model call: it does not fire request/response observability events.

Method Summary

Modifier and Type	Method	Description
static CompletableFuture<ChatResponse>	chatAsync(StreamingChatModel streamingChatModel, ChatRequest request)
static CompletableFuture<ChatResponse>	chatAsync(StreamingChatModel streamingChatModel, ChatRequest request, Consumer<Throwable> errorHandler)	As chatAsync(StreamingChatModel, ChatRequest), but additionally notifies errorHandler (if non-null) when the stream fails, before the returned future completes exceptionally.

Methods inherited from class Object

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

Method Details

chatAsync

public static CompletableFuture<ChatResponse> chatAsync(StreamingChatModel streamingChatModel,
 ChatRequest request)

chatAsync

public static CompletableFuture<ChatResponse> chatAsync(StreamingChatModel streamingChatModel,
 ChatRequest request,
 Consumer<Throwable> errorHandler)

As chatAsync(StreamingChatModel, ChatRequest), but additionally notifies errorHandler (if non-null) when the stream fails, before the returned future completes exceptionally.