StdioAcpAgentTransport

java.lang.Object
- com.agentclientprotocol.sdk.agent.transport.StdioAcpAgentTransport

所有已实现的接口:

AcpAgentTransport, AcpTransport
```
public class StdioAcpAgentTransport
extends java.lang.Object
implements AcpAgentTransport
```
Implementation of the ACP Stdio transport for agents that communicates with clients using standard input/output streams. Messages are exchanged as newline-delimited JSON-RPC messages over stdin/stdout, with errors and debug information sent to stderr.
This is the agent-side counterpart to StdioAcpClientTransport. While the client spawns an agent process and connects to its stdin/stdout, the agent transport reads from the process's System.in and writes to System.out.

Key features:
- Thread-safe message processing with dedicated schedulers
- Proper resource management and graceful shutdown
- Backpressure support via Reactor Sinks

构造器概要

构造器
构造器和说明
`StdioAcpAgentTransport()` Creates a new StdioAcpAgentTransport with the default JsonMapper using System.in and System.out for communication.
`StdioAcpAgentTransport(McpJsonMapper jsonMapper)` Creates a new StdioAcpAgentTransport with the specified JsonMapper using System.in and System.out for communication.
`StdioAcpAgentTransport(McpJsonMapper jsonMapper, java.io.InputStream inputStream, java.io.OutputStream outputStream)` Creates a new StdioAcpAgentTransport with the specified JsonMapper and streams.

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`reactor.core.publisher.Mono<java.lang.Void>`	`awaitTermination()` Returns a Mono that completes when the transport terminates.
`reactor.core.publisher.Mono<java.lang.Void>`	`closeGracefully()` Closes the transport connection and releases any associated resources asynchronously.
`java.util.List<java.lang.Integer>`	`protocolVersions()` Returns the list of protocol versions supported by this transport.
`reactor.core.publisher.Mono<java.lang.Void>`	`sendMessage(AcpSchema.JSONRPCMessage message)` Sends a message to the peer asynchronously.
`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.
`<T> T`	`unmarshalFrom(java.lang.Object data, TypeRef<T> typeRef)` Unmarshals the given data into an object of the specified type.

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

- 构造器详细资料
  - StdioAcpAgentTransport
```
public StdioAcpAgentTransport()
```
    Creates a new StdioAcpAgentTransport with the default JsonMapper using System.in and System.out for communication.
  - StdioAcpAgentTransport
```
public StdioAcpAgentTransport(McpJsonMapper jsonMapper)
```
    Creates a new StdioAcpAgentTransport with the specified JsonMapper using System.in and System.out for communication.
    
    参数:
    
    jsonMapper - The JsonMapper to use for JSON serialization/deserialization
  - StdioAcpAgentTransport
```
public StdioAcpAgentTransport(McpJsonMapper jsonMapper,
                              java.io.InputStream inputStream,
                              java.io.OutputStream outputStream)
```
    Creates a new StdioAcpAgentTransport with the specified JsonMapper and streams. This constructor allows for custom streams (useful for testing).
    
    参数:
    
    jsonMapper - The JsonMapper to use for JSON serialization/deserialization
    
    inputStream - The input stream to read messages from (client → agent)
    
    outputStream - The output stream to write messages to (agent → client)
- 方法详细资料
  - protocolVersions
```
public java.util.List<java.lang.Integer> protocolVersions()
```
    从接口复制的说明: AcpTransport
    
    Returns the list of protocol versions supported by this transport.
    
    指定者:
    
    protocolVersions 在接口中 AcpTransport
    
    返回:
    
    list of supported protocol versions
  - start
```
public 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)
```
    从接口复制的说明: AcpAgentTransport
    
    Used to register the incoming messages' handler and start listening for client connections.
    
    指定者:
    
    start 在接口中 AcpAgentTransport
    
    参数:
    
    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.
  - sendMessage
```
public reactor.core.publisher.Mono<java.lang.Void> sendMessage(AcpSchema.JSONRPCMessage message)
```
    从接口复制的说明: AcpTransport
    
    Sends a message to the peer asynchronously.
    This method handles the transmission of messages to the peer in an asynchronous manner. Messages are sent in JSON-RPC format as specified by the ACP protocol.
    
    指定者:
    
    sendMessage 在接口中 AcpTransport
    
    参数:
    
    message - the AcpSchema.JSONRPCMessage to be sent to the peer
    
    返回:
    
    a Mono that completes when the message has been sent
  - closeGracefully
```
public reactor.core.publisher.Mono<java.lang.Void> closeGracefully()
```
    从接口复制的说明: AcpTransport
    
    Closes the transport connection and releases any associated resources asynchronously.
    
    指定者:
    
    closeGracefully 在接口中 AcpTransport
    
    返回:
    
    a Mono that completes when the connection has been closed.
  - setExceptionHandler
```
public void setExceptionHandler(java.util.function.Consumer<java.lang.Throwable> handler)
```
    从接口复制的说明: AcpAgentTransport
    
    Sets the exception handler for exceptions raised on the transport layer.
    
    指定者:
    
    setExceptionHandler 在接口中 AcpAgentTransport
    
    参数:
    
    handler - Allows reacting to transport level exceptions by the higher layers
  - awaitTermination
```
public reactor.core.publisher.Mono<java.lang.Void> awaitTermination()
```
    从接口复制的说明: AcpAgentTransport
    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
 
```
    指定者:
    
    awaitTermination 在接口中 AcpAgentTransport
    
    返回:
    
    a Mono that completes when the transport terminates
  - unmarshalFrom
```
public <T> T unmarshalFrom(java.lang.Object data,
                           TypeRef<T> typeRef)
```
    从接口复制的说明: AcpTransport
    
    Unmarshals the given data into an object of the specified type.
    
    指定者:
    
    unmarshalFrom 在接口中 AcpTransport
    
    类型参数:
    
    T - the type of the object to unmarshal
    
    参数:
    
    data - the data to unmarshal
    
    typeRef - the type reference for the object to unmarshal
    
    返回:
    
    the unmarshalled object

类 StdioAcpAgentTransport

构造器概要

方法概要

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

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

构造器详细资料

StdioAcpAgentTransport

StdioAcpAgentTransport

StdioAcpAgentTransport

方法详细资料

protocolVersions

start

sendMessage

closeGracefully

setExceptionHandler

awaitTermination

unmarshalFrom