com.agentclientprotocol.sdk.spec

类 AcpClientSession

java.lang.Object

com.agentclientprotocol.sdk.spec.AcpClientSession

所有已实现的接口:

AcpSession

public class AcpClientSession
extends java.lang.Object
implements AcpSession

Default implementation of the ACP (Agent Client Protocol) client session that manages bidirectional JSON-RPC communication between clients and agents. This implementation follows the ACP specification for message exchange and transport handling.

The session manages:

• Request/response handling with unique message IDs
• Notification processing
• Message timeout management
• Transport layer abstraction

This is the client-side session that sends requests to an agent (initialize, newSession, prompt, etc.) and handles incoming requests from the agent (readTextFile, writeTextFile, requestPermission, etc.)

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	AcpClientSession.AcpError ACP-specific error wrapper for JSON-RPC errors.
static class	AcpClientSession.MethodNotFoundError
static interface	AcpClientSession.NotificationHandler Functional interface for handling incoming JSON-RPC notifications.
static interface	AcpClientSession.RequestHandler<T> Functional interface for handling incoming JSON-RPC requests.

构造器概要

构造器

构造器和说明

AcpClientSession(java.time.Duration requestTimeout, AcpClientTransport transport, java.util.Map<java.lang.String,AcpClientSession.RequestHandler<?>> requestHandlers, java.util.Map<java.lang.String,AcpClientSession.NotificationHandler> notificationHandlers, java.util.function.Function<? super reactor.core.publisher.Mono<java.lang.Void>,? extends org.reactivestreams.Publisher<java.lang.Void>> connectHook) Creates a new AcpClientSession with the specified configuration and handlers.

方法概要

限定符和类型	方法和说明
void	close() Closes the session immediately, potentially interrupting pending operations.
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Closes the session gracefully, allowing pending operations to complete.
reactor.core.publisher.Mono<java.lang.Void>	sendNotification(java.lang.String method, java.lang.Object params) Sends a JSON-RPC notification.
<T> reactor.core.publisher.Mono<T>	sendRequest(java.lang.String method, java.lang.Object requestParams, TypeRef<T> typeRef) Sends a JSON-RPC request and returns the response.

从类继承的方法 java.lang.Object

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

从接口继承的方法 com.agentclientprotocol.sdk.spec.AcpSession

sendNotification

构造器详细资料

AcpClientSession

public AcpClientSession(java.time.Duration requestTimeout,
                        AcpClientTransport transport,
                        java.util.Map<java.lang.String,AcpClientSession.RequestHandler<?>> requestHandlers,
                        java.util.Map<java.lang.String,AcpClientSession.NotificationHandler> notificationHandlers,
                        java.util.function.Function<? super reactor.core.publisher.Mono<java.lang.Void>,? extends org.reactivestreams.Publisher<java.lang.Void>> connectHook)

Creates a new AcpClientSession with the specified configuration and handlers.

参数:

requestTimeout - Duration to wait for responses

transport - Transport implementation for message exchange

requestHandlers - Map of method names to request handlers

notificationHandlers - Map of method names to notification handlers

connectHook - Hook that allows transforming the connection Publisher prior to subscribing

方法详细资料

sendRequest

public <T> reactor.core.publisher.Mono<T> sendRequest(java.lang.String method,
                                                      java.lang.Object requestParams,
                                                      TypeRef<T> typeRef)

Sends a JSON-RPC request and returns the response.

指定者:

sendRequest 在接口中 AcpSession

类型参数:

T - The expected response type

参数:

method - The method name to call

requestParams - The request parameters

typeRef - Type reference for response deserialization

返回:

A Mono containing the response

sendNotification

public reactor.core.publisher.Mono<java.lang.Void> sendNotification(java.lang.String method,
                                                                    java.lang.Object params)

Sends a JSON-RPC notification.

指定者:

sendNotification 在接口中 AcpSession

参数:

method - The method name for the notification

params - The notification parameters

返回:

A Mono that completes when the notification is sent

closeGracefully

public reactor.core.publisher.Mono<java.lang.Void> closeGracefully()

Closes the session gracefully, allowing pending operations to complete.

指定者:

closeGracefully 在接口中 AcpSession

返回:

A Mono that completes when the session is closed

close

public void close()

Closes the session immediately, potentially interrupting pending operations.

指定者:

close 在接口中 AcpSession