Class AnthropicClient

java.lang.Object

dev.langchain4j.model.anthropic.internal.client.AnthropicClient

Direct Known Subclasses:

DefaultAnthropicClient

public abstract class AnthropicClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AnthropicClient.Builder<T extends AnthropicClient, B extends AnthropicClient.Builder<T,B>>	Builder class for constructing AnthropicClient instances.

Constructor Summary

Constructors

Constructor	Description
AnthropicClient()

Method Summary

Modifier and Type	Method	Description
static AnthropicClient.Builder	builder()
AnthropicBatch	cancelBatch(String batchId)
MessageTokenCountResponse	countTokens(AnthropicCountTokensRequest request)
AnthropicBatch	createBatch(AnthropicCreateBatchRequest request)
abstract AnthropicCreateMessageResponse	createMessage(AnthropicCreateMessageRequest request)
void	createMessage(AnthropicCreateMessageRequest request, AnthropicCreateMessageOptions options, StreamingChatResponseHandler handler)
abstract void	createMessage(AnthropicCreateMessageRequest request, StreamingChatResponseHandler handler)
Flow.Publisher<ChatModelStreamingEvent>	createMessagePublisher(AnthropicCreateMessageRequest request, AnthropicCreateMessageOptions options, int bufferSize)	Non-blocking reactive streaming counterpart of createMessage(AnthropicCreateMessageRequest, AnthropicCreateMessageOptions, StreamingChatResponseHandler): returns a Publisher of ChatModelStreamingEvents driven by httpClient.stream(...) (nothing parked on socket reads); bufferSize bounds the back-pressure buffer, and cancelling the subscription aborts the in-flight HTTP request.
ParsedAndRawResponse	createMessageWithRawResponse(AnthropicCreateMessageRequest request)
CompletableFuture<ParsedAndRawResponse>	createMessageWithRawResponseAsync(AnthropicCreateMessageRequest request)	Non-blocking counterpart of createMessageWithRawResponse(AnthropicCreateMessageRequest): sends the request without holding a thread while the response is in flight.
AnthropicListBatchesResponse	listBatches(Integer limit, String afterId)
AnthropicModelsListResponse	listModels()
AnthropicBatch	retrieveBatch(String batchId)
List<AnthropicBatchResult>	retrieveBatchResults(String batchId)

Methods inherited from class Object

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

Constructor Details

AnthropicClient

public AnthropicClient()

Method Details

createMessage

public abstract AnthropicCreateMessageResponse createMessage(AnthropicCreateMessageRequest request)

createMessageWithRawResponse

public ParsedAndRawResponse createMessageWithRawResponse(AnthropicCreateMessageRequest request)

createMessageWithRawResponseAsync

public CompletableFuture<ParsedAndRawResponse> createMessageWithRawResponseAsync(AnthropicCreateMessageRequest request)

Non-blocking counterpart of createMessageWithRawResponse(AnthropicCreateMessageRequest): sends the request without holding a thread while the response is in flight. The default returns a failed future carrying AsyncNotSupportedException to signal that this client has no native asynchronous path.

Since:

1.20.0

createMessage

public void createMessage(AnthropicCreateMessageRequest request,
 AnthropicCreateMessageOptions options,
 StreamingChatResponseHandler handler)

Since:

1.2.0

createMessage

public abstract void createMessage(AnthropicCreateMessageRequest request,
 StreamingChatResponseHandler handler)

createMessagePublisher

public Flow.Publisher<ChatModelStreamingEvent> createMessagePublisher(AnthropicCreateMessageRequest request,
 AnthropicCreateMessageOptions options,
 int bufferSize)

Non-blocking reactive streaming counterpart of createMessage(AnthropicCreateMessageRequest, AnthropicCreateMessageOptions, StreamingChatResponseHandler): returns a Publisher of ChatModelStreamingEvents driven by httpClient.stream(...) (nothing parked on socket reads); bufferSize bounds the back-pressure buffer, and cancelling the subscription aborts the in-flight HTTP request. The default returns a failing Publisher carrying AsyncNotSupportedException.

Since:

1.20.0

countTokens

public MessageTokenCountResponse countTokens(AnthropicCountTokensRequest request)

listModels

public AnthropicModelsListResponse listModels()

createBatch

public AnthropicBatch createBatch(AnthropicCreateBatchRequest request)

retrieveBatch

public AnthropicBatch retrieveBatch(String batchId)

retrieveBatchResults

public List<AnthropicBatchResult> retrieveBatchResults(String batchId)

cancelBatch

public AnthropicBatch cancelBatch(String batchId)

listBatches

public AnthropicListBatchesResponse listBatches(Integer limit,
 String afterId)

builder

public static AnthropicClient.Builder builder()