AcpAsyncAgent

```
public interface AcpAsyncAgent
```
Asynchronous ACP agent interface providing non-blocking operations for handling client requests and sending notifications.
The agent is the server-side component in the ACP protocol, responsible for:
- Responding to client initialization and authentication requests
- Managing sessions and processing prompts
- Sending session update notifications during processing
- Requesting client capabilities (file system, terminal, permissions)
另请参阅:

AcpAgent, AcpSyncAgent

方法概要

所有方法实例方法抽象方法
限定符和类型	方法和说明
`reactor.core.publisher.Mono<java.lang.Void>`	`awaitTermination()` Returns a Mono that completes when the agent terminates.
`void`	`close()` Closes the agent immediately.
`reactor.core.publisher.Mono<java.lang.Void>`	`closeGracefully()` Closes the agent gracefully, allowing pending operations to complete.
`reactor.core.publisher.Mono<AcpSchema.CreateTerminalResponse>`	`createTerminal(AcpSchema.CreateTerminalRequest request)` Requests the client to create a terminal.
`NegotiatedCapabilities`	`getClientCapabilities()` Returns the capabilities negotiated with the client during initialization.
`reactor.core.publisher.Mono<AcpSchema.TerminalOutputResponse>`	`getTerminalOutput(AcpSchema.TerminalOutputRequest request)` Requests terminal output from the client.
`reactor.core.publisher.Mono<AcpSchema.KillTerminalCommandResponse>`	`killTerminal(AcpSchema.KillTerminalCommandRequest request)` Requests the client to kill a terminal.
`reactor.core.publisher.Mono<AcpSchema.ReadTextFileResponse>`	`readTextFile(AcpSchema.ReadTextFileRequest request)` Requests the client to read a text file.
`reactor.core.publisher.Mono<AcpSchema.ReleaseTerminalResponse>`	`releaseTerminal(AcpSchema.ReleaseTerminalRequest request)` Requests the client to release a terminal.
`reactor.core.publisher.Mono<AcpSchema.RequestPermissionResponse>`	`requestPermission(AcpSchema.RequestPermissionRequest request)` Requests permission from the client for a sensitive operation.
`reactor.core.publisher.Mono<java.lang.Void>`	`sendSessionUpdate(java.lang.String sessionId, AcpSchema.SessionUpdate update)` Sends a session update notification to the client.
`reactor.core.publisher.Mono<java.lang.Void>`	`start()` Starts the agent, beginning to accept client connections.
`reactor.core.publisher.Mono<AcpSchema.WaitForTerminalExitResponse>`	`waitForTerminalExit(AcpSchema.WaitForTerminalExitRequest request)` Waits for a terminal to exit.
`reactor.core.publisher.Mono<AcpSchema.WriteTextFileResponse>`	`writeTextFile(AcpSchema.WriteTextFileRequest request)` Requests the client to write a text file.

- 方法详细资料
  - start
```
reactor.core.publisher.Mono<java.lang.Void> start()
```
    Starts the agent, beginning to accept client connections.
    
    返回:
    
    A Mono that completes when the agent is started
  - awaitTermination
```
reactor.core.publisher.Mono<java.lang.Void> awaitTermination()
```
    Returns a Mono that completes when the agent terminates. This is useful for blocking until the transport closes, particularly when using daemon threads.
    Example usage:
```
 agent.start().block();
 agent.awaitTermination().block(); // Block until transport closes
 
```
    返回:
    
    A Mono that completes when the agent terminates
  - getClientCapabilities
```
NegotiatedCapabilities getClientCapabilities()
```
    Returns the capabilities negotiated with the client during initialization.
    This method returns null if initialization has not been completed yet. Use this to check what features the client supports before calling methods like readTextFile(com.agentclientprotocol.sdk.spec.AcpSchema.ReadTextFileRequest) or createTerminal(com.agentclientprotocol.sdk.spec.AcpSchema.CreateTerminalRequest).
    
    返回:
    
    the negotiated client capabilities, or null if not initialized
  - sendSessionUpdate
```
reactor.core.publisher.Mono<java.lang.Void> sendSessionUpdate(java.lang.String sessionId,
                                                              AcpSchema.SessionUpdate update)
```
    Sends a session update notification to the client. Used for streaming updates during prompt processing.
    
    参数:
    
    sessionId - The session ID
    
    update - The session update to send
    
    返回:
    
    A Mono that completes when the notification is sent
  - requestPermission
```
reactor.core.publisher.Mono<AcpSchema.RequestPermissionResponse> requestPermission(AcpSchema.RequestPermissionRequest request)
```
    Requests permission from the client for a sensitive operation.
    
    参数:
    
    request - The permission request
    
    返回:
    
    A Mono containing the permission response
  - readTextFile
```
reactor.core.publisher.Mono<AcpSchema.ReadTextFileResponse> readTextFile(AcpSchema.ReadTextFileRequest request)
```
    Requests the client to read a text file.
    
    参数:
    
    request - The read file request
    
    返回:
    
    A Mono containing the file content
  - writeTextFile
```
reactor.core.publisher.Mono<AcpSchema.WriteTextFileResponse> writeTextFile(AcpSchema.WriteTextFileRequest request)
```
    Requests the client to write a text file.
    
    参数:
    
    request - The write file request
    
    返回:
    
    A Mono that completes when the file is written
  - createTerminal
```
reactor.core.publisher.Mono<AcpSchema.CreateTerminalResponse> createTerminal(AcpSchema.CreateTerminalRequest request)
```
    Requests the client to create a terminal.
    
    参数:
    
    request - The create terminal request
    
    返回:
    
    A Mono containing the terminal ID
  - getTerminalOutput
```
reactor.core.publisher.Mono<AcpSchema.TerminalOutputResponse> getTerminalOutput(AcpSchema.TerminalOutputRequest request)
```
    Requests terminal output from the client.
    
    参数:
    
    request - The terminal output request
    
    返回:
    
    A Mono containing the terminal output
  - releaseTerminal
```
reactor.core.publisher.Mono<AcpSchema.ReleaseTerminalResponse> releaseTerminal(AcpSchema.ReleaseTerminalRequest request)
```
    Requests the client to release a terminal.
    
    参数:
    
    request - The release terminal request
    
    返回:
    
    A Mono that completes when the terminal is released
  - waitForTerminalExit
```
reactor.core.publisher.Mono<AcpSchema.WaitForTerminalExitResponse> waitForTerminalExit(AcpSchema.WaitForTerminalExitRequest request)
```
    Waits for a terminal to exit.
    
    参数:
    
    request - The wait for exit request
    
    返回:
    
    A Mono containing the exit status
  - killTerminal
```
reactor.core.publisher.Mono<AcpSchema.KillTerminalCommandResponse> killTerminal(AcpSchema.KillTerminalCommandRequest request)
```
    Requests the client to kill a terminal.
    
    参数:
    
    request - The kill terminal request
    
    返回:
    
    A Mono that completes when the terminal is killed
  - closeGracefully
```
reactor.core.publisher.Mono<java.lang.Void> closeGracefully()
```
    Closes the agent gracefully, allowing pending operations to complete.
    
    返回:
    
    A Mono that completes when the agent is closed
  - close
```
void close()
```
    Closes the agent immediately.

接口 AcpAsyncAgent

方法概要

方法详细资料

start

awaitTermination

getClientCapabilities

sendSessionUpdate

requestPermission

readTextFile

writeTextFile

createTerminal

getTerminalOutput

releaseTerminal

waitForTerminalExit

killTerminal

closeGracefully

close