A2AStreamingHandler

class A2AStreamingHandler(objectMapper: <Error class: unknown class>, taskStateManager: TaskStateManager)

Handles streaming functionality for A2A messages

Constructors

constructor(objectMapper: <Error class: unknown class>, taskStateManager: TaskStateManager)

Closes the specified stream

fun createStream(streamId: String, taskId: String? = null, contextId: String? = null): <Error class: unknown class>

Creates a new SSE stream for the given stream ID

fun resubscribeToTask(taskId: String, newStreamId: String): <Error class: unknown class>

Resubscribes to an existing task by creating a new stream and replaying events

fun sendStreamEvent(streamId: String, event: <Error class: unknown class>, taskId: String? = null)

Sends a streaming event to the specified stream and records it for the task

Shuts down the streaming handler