send
fun sendStreaming(request: <Error class: unknown class>, timeoutMs: Long? = null, locale: String? = null): Flow<<Error class: unknown class>>
Opens a server-streaming SendStreamingMessage call and emits each response in arrival order.
If the call fails with UNAUTHENTICATED before any response was delivered, a fresh token is requested and the call is retried once. After the first response, errors are never retried. Cancelling the collector cancels the underlying RPC.
Parameters
request
send-streaming request payload to send to the A2A service
timeout
optional deadline for the whole turn; expiry fails the flow with DEADLINE_EXCEEDED
locale
language of the user's input for the x-language header; the device locale when null
Throws
if no valid token is available