com.agentclientprotocol.sdk.spec

接口 AcpAgentTransport

所有超级接口:

AcpTransport

所有已知实现类:

StdioAcpAgentTransport, WebSocketSolonAcpAgentTransport

public interface AcpAgentTransport
extends AcpTransport

Interface for the agent side of the AcpTransport. It allows setting handlers for messages that are incoming from the ACP client and hooking in to exceptions raised on the transport layer.

The agent transport is used by agent implementations that want to receive requests from code editors/clients through the Agent Client Protocol.

方法概要

限定符和类型	方法和说明
reactor.core.publisher.Mono<java.lang.Void>	awaitTermination() Returns a Mono that completes when the transport terminates.
default void	setExceptionHandler(java.util.function.Consumer<java.lang.Throwable> handler) Sets the exception handler for exceptions raised on the transport layer.
reactor.core.publisher.Mono<java.lang.Void>	start(java.util.function.Function<reactor.core.publisher.Mono<AcpSchema.JSONRPCMessage>,reactor.core.publisher.Mono<AcpSchema.JSONRPCMessage>> handler) Used to register the incoming messages' handler and start listening for client connections.

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

close, closeGracefully, protocolVersions, sendMessage, unmarshalFrom

方法详细资料

start

reactor.core.publisher.Mono<java.lang.Void> start(java.util.function.Function<reactor.core.publisher.Mono<AcpSchema.JSONRPCMessage>,reactor.core.publisher.Mono<AcpSchema.JSONRPCMessage>> handler)

Used to register the incoming messages' handler and start listening for client connections.

参数:

handler - a transformer for incoming messages

返回:

a Mono that terminates upon successful agent setup. The successful termination of the returned Mono simply means the agent can now receive requests. An error can be retried according to the application requirements.

setExceptionHandler

default void setExceptionHandler(java.util.function.Consumer<java.lang.Throwable> handler)

Sets the exception handler for exceptions raised on the transport layer.

参数:

handler - Allows reacting to transport level exceptions by the higher layers

awaitTermination

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

Returns a Mono that completes when the transport terminates. This is useful for agents that need to block until the transport is done, particularly when using daemon threads.

Example usage:

 transport.start(handler).block();
 transport.awaitTermination().block(); // Block until stdin closes
 

返回:

a Mono that completes when the transport terminates