A2AStreamingHandler

class A2AStreamingHandler(objectMapper: <Error class: unknown class>)

Handles streaming functionality for A2A messages

Constructors

Link copied to clipboard
constructor(objectMapper: <Error class: unknown class>)

Functions

Link copied to clipboard
fun closeStream(streamId: String)

Closes the specified stream

Link copied to clipboard
fun createStream(streamId: String): <Error class: unknown class>

Creates a new SSE stream for the given stream ID

Link copied to clipboard
fun sendStreamEvent(streamId: String, event: <Error class: unknown class>)

Sends a streaming event to the specified stream

Link copied to clipboard
fun shutdown()

Shuts down the streaming handler