ai-mocks-a2a-models/dev.mokksy.aimocks.a2a.model/SendStreamingMessageResponseBuilder

SendStreamingMessageResponseBuilder

class SendStreamingMessageResponseBuilder(source)

Builder class for creating SendStreamingMessageResponse instances.

This builder provides a fluent API for creating SendStreamingMessageResponse objects, making it easier to configure streaming message responses according to the A2A protocol.

The result field accepts polymorphic TaskUpdateEvent instances (TaskStatusUpdateEvent or TaskArtifactUpdateEvent).

Example usage:

val response = sendStreamingMessageResponse {
    id = "request-789"
    taskStatusUpdate {
        id("task-streaming-123")
        status {
            state = TaskState.working
            timestamp = System.currentTimeMillis()
        }
        final = false
    }
}

See also

A2A Protocol - Streaming Messages

Constructors

SendStreamingMessageResponseBuilder

constructor()

Properties

var error: JSONRPCError?

var id: String?

var result: TaskUpdateEvent?

Functions

fun build(): SendStreamingMessageResponse

Builds a SendStreamingMessageResponse instance with the configured parameters.

fun error(error: JSONRPCError): SendStreamingMessageResponseBuilder

Sets the error for the response.

fun id(id: String): SendStreamingMessageResponseBuilder

Sets the ID of the response.

fun result(result: TaskUpdateEvent): SendStreamingMessageResponseBuilder

Sets the result task update event.

taskArtifactUpdate

fun taskArtifactUpdate(init: Consumer<TaskArtifactUpdateEventBuilder>): SendStreamingMessageResponseBuilder

Configures a task artifact update event using a Java-friendly Consumer.

fun taskArtifactUpdate(init: TaskArtifactUpdateEventBuilder.() -> Unit): SendStreamingMessageResponseBuilder

Configures a task artifact update event using a lambda with receiver.

taskStatusUpdate

fun taskStatusUpdate(init: Consumer<TaskStatusUpdateEventBuilder>): SendStreamingMessageResponseBuilder

Configures a task status update event using a Java-friendly Consumer.

fun taskStatusUpdate(init: TaskStatusUpdateEventBuilder.() -> Unit): SendStreamingMessageResponseBuilder

Configures a task status update event using a lambda with receiver.