Class AsyncNotSupported

java.lang.Object

dev.langchain4j.internal.AsyncNotSupported

public final class AsyncNotSupported
extends Object

Factory for the "not implemented" result of an asynchronous / reactive SPI default method.

The async and reactive SPI methods (e.g. ChatModel.doChatAsync, EmbeddingStore.searchAsync, StreamingChatModel.doChat(ChatRequest)) ship a default body for providers that have not opted into the non-blocking path. Rather than throwing AsyncNotSupportedException synchronously - which would escape the method's own return-type contract, so whether it is safe depends on whether the call site happened to be inside a future/publisher stage that launders the throw - the defaults signal the failure through their return type's error channel: a failed CompletableFuture for future-returning methods, or an immediately-failing Flow.Publisher for publisher-returning methods. The framework's offload-or-fail-loud orchestration then observes it uniformly (via exceptionallyCompose/onError), regardless of context.

This does not change genuine implementations, nor the public entry points (chatAsync, embedAsync, the AI-Service dispatch), which still convert their own synchronous validate(request) failures.

Since:

1.20.0

Method Summary

Modifier and Type	Method	Description
static <T> CompletableFuture<T>	failedFuture(Class<?> implementationType, String methodName)
static <T> CompletableFuture<T>	failedFuture(String message)
static <T> Flow.Publisher<T>	failingPublisher(Class<?> implementationType, String methodName)
static <T> Flow.Publisher<T>	failingPublisher(String message)

Methods inherited from class Object

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

Method Details

failedFuture

public static <T> CompletableFuture<T> failedFuture(Class<?> implementationType,
 String methodName)

Returns:

an already-failed future carrying an AsyncNotSupportedException whose message follows the convention "<methodName>() is not implemented by <implementationType>".

failedFuture

public static <T> CompletableFuture<T> failedFuture(String message)

Returns:

an already-failed future carrying an AsyncNotSupportedException with the given message (for defaults that provide their own, more detailed guidance).

failingPublisher

public static <T> Flow.Publisher<T> failingPublisher(Class<?> implementationType,
 String methodName)

Returns:

a cold Flow.Publisher that, on subscribe, immediately signals onError with an AsyncNotSupportedException whose message follows the convention "<methodName>() is not implemented by <implementationType>".

failingPublisher

public static <T> Flow.Publisher<T> failingPublisher(String message)

Returns:

a cold Flow.Publisher that, on subscribe, immediately signals onError with an AsyncNotSupportedException carrying the given message.