a2a-client/dev.mokksy.a2a.client/A2AClient

A2AClient

interface A2AClient(source)

Client for interacting with an A2A (Agent-to-Agent) server.

This client provides methods for all operations supported by the A2A protocol, including sending tasks, getting tasks, canceling tasks, and managing push notifications. It also supports streaming operations for real-time task updates.

The A2A protocol enables communication between AI agents, allowing them to work together on complex tasks. This client implementation handles the HTTP communication details and data serialization/deserialization required by the protocol.

Inheritors

DefaultA2AClient

Properties

abstract val httpClient: HttpClient

Gets the underlying HTTP client.

Functions

abstract suspend fun cancelTask(request: CancelTaskRequest): CancelTaskResponse

Cancels a task on the server using a pre-constructed request object.

abstract suspend fun cancelTask(id: TaskId): CancelTaskResponse

Cancels a task on the server.

abstract fun close()

Closes the client and releases resources.

abstract suspend fun getAgentCard(): AgentCard

Gets the agent card from the server.

abstract suspend fun getTask(request: GetTaskRequest): GetTaskResponse

Gets a task from the server using a pre-constructed request object.

abstract suspend fun getTask(id: TaskId, historyLength: Int? = null): GetTaskResponse

Gets a task from the server.

getTaskPushNotification

abstract suspend fun getTaskPushNotification(request: GetTaskPushNotificationRequest): GetTaskPushNotificationResponse

Gets the push notification configuration for a task using a pre-constructed request object.

abstract suspend fun getTaskPushNotification(id: TaskId): GetTaskPushNotificationResponse

Gets the push notification configuration for a task.

resubscribeToTask

abstract fun resubscribeToTask(id: TaskId): Flow<TaskUpdateEvent>

Resubscribes to streaming updates for a task.

abstract suspend fun sendMessage(params: MessageSendParams): SendMessageResponse

Sends a message to an agent using the A2A protocol's message/send method.

abstract suspend fun sendMessage(request: SendMessageRequest): SendMessageResponse

Sends a message to an agent using a pre-constructed request object.

sendStreamingMessage

abstract fun sendStreamingMessage(params: MessageSendParams): Flow<TaskUpdateEvent>

Sends a message to an agent with streaming updates using the A2A protocol's message/stream method.

abstract fun sendStreamingMessage(request: SendStreamingMessageRequest): Flow<TaskUpdateEvent>

Sends a message to an agent with streaming updates using a pre-constructed request object.

sendStreamingMessageAsJavaFlow

@DelicateCoroutinesApi

fun A2AClient.sendStreamingMessageAsJavaFlow(params: MessageSendParams, executor: Executor, maxBufferCapacity: Int = 64): Flow.Publisher<TaskUpdateEvent>

setTaskPushNotification

abstract suspend fun setTaskPushNotification(request: SetTaskPushNotificationRequest): SetTaskPushNotificationResponse

Sets push notification configuration for a task using a pre-constructed request object.

abstract suspend fun setTaskPushNotification(id: TaskId, config: PushNotificationConfig): SetTaskPushNotificationResponse

Sets push notification configuration for a task.