Package dev.langchain4j.model

Class LambdaStreamingResponseHandler<T>

java.lang.Object

dev.langchain4j.model.LambdaStreamingResponseHandler<T>

Type Parameters:

T - The type of the response.

public class LambdaStreamingResponseHandler<T>
extends Object

Utility class with lambda-based streaming response handlers. Lets you use Java lambda functions to receive onNext and onError events, from your streaming chat model, instead of creating an anonymous inner class implementing StreamingResponseHandler. Example:

 import static dev.langchain4j.model.LambdaStreamingResponseHandler.*;

 model.generate("Why is the sky blue?",
       onNext(text -> System.out.println(text));
 model.generate("Why is the sky blue?",
       onNext(System.out::println);
 model.generate("Why is the sky blue?",
       onNextAndError(System.out::println, Throwable::printStackTrace));
 

See Also:

• StreamingResponseHandler.onNext(String)
• StreamingResponseHandler.onError(Throwable)

Constructor Summary

Constructors

Constructor	Description
LambdaStreamingResponseHandler()

Method Summary

Modifier and Type	Method	Description
static <T> StreamingResponseHandler<T>	onNext(Consumer<String> nextLambda)
static <T> StreamingResponseHandler<T>	onNextAndError(Consumer<String> nextLambda, Consumer<Throwable> errorLambda)

Methods inherited from class java.lang.Object

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

Constructor Details

LambdaStreamingResponseHandler

public LambdaStreamingResponseHandler()

Method Details

onNext

public static <T> StreamingResponseHandler<T> onNext(Consumer<String> nextLambda)

onNextAndError

public static <T> StreamingResponseHandler<T> onNextAndError(Consumer<String> nextLambda,
 Consumer<Throwable> errorLambda)