a2a-client/dev.mokksy.a2a.client/DefaultA2AClient

DefaultA2AClient

open class DefaultA2AClient(val httpClient: HttpClient, baseUrl: String, json: Json = Json { ignoreUnknownKeys = true isLenient = true }, requestConfigurer: HttpRequestBuilder.() -> Unit = { }) : A2AClient(source)

Default implementation of the A2AClient interface.

Constructors

DefaultA2AClient

constructor(httpClient: HttpClient, baseUrl: String, json: Json = Json { ignoreUnknownKeys = true isLenient = true }, requestConfigurer: HttpRequestBuilder.() -> Unit = { })

Properties

httpClient

open override val httpClient: HttpClient

The Ktor HTTP client used for making requests.

Functions

cancelTask

open suspend override fun cancelTask(request: CancelTaskRequest): CancelTaskResponse

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

open suspend override fun cancelTask(id: TaskId): CancelTaskResponse

Cancels a task on the server.

open override fun close()

Closes the client and releases resources.

getAgentCard

open suspend override fun getAgentCard(): AgentCard

Gets the agent card from the server.

getTask

open suspend override fun getTask(request: GetTaskRequest): GetTaskResponse

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

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

Gets a task from the server.

getTaskPushNotification

open suspend override fun getTaskPushNotification(request: GetTaskPushNotificationRequest): GetTaskPushNotificationResponse

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

open suspend override fun getTaskPushNotification(id: TaskId): GetTaskPushNotificationResponse

Gets the push notification configuration for a task.

resubscribeToTask

open override fun resubscribeToTask(id: TaskId): Flow<TaskUpdateEvent>

Resubscribes to streaming updates for a task.

sendMessage

open suspend override fun sendMessage(params: MessageSendParams): SendMessageResponse

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

open suspend override fun sendMessage(request: SendMessageRequest): SendMessageResponse

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

sendStreamingMessage

open override fun sendStreamingMessage(params: MessageSendParams): Flow<TaskUpdateEvent>

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

open override fun sendStreamingMessage(request: SendStreamingMessageRequest): Flow<TaskUpdateEvent>

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

sendStreamingMessageAsJavaFlow

@DelicateCoroutinesApi

@JvmOverloads

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

setTaskPushNotification

open suspend override fun setTaskPushNotification(request: SetTaskPushNotificationRequest): SetTaskPushNotificationResponse

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

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

Sets push notification configuration for a task.