google-adk-kotlin-core/com.google.adk.kt.agents/LiveRequestQueue

LiveRequestQueue

class LiveRequestQueue @ExperimentalLiveApi constructor : AutoCloseable

The input side of a live conversation: everything the user sends reaches the agent through one of these, from any thread and without suspending, so audio can be pushed from a microphone callback or a UI handler without a coroutine.

The cost is an unbounded queue: a producer faster than the agent grows it without limit, an entry per audio chunk spoken.

ADK Python makes the same trade, with an asyncio.Queue that sets no maximum.

Constructors

LiveRequestQueue

@ExperimentalLiveApi

constructor()

Functions

open override fun close()

Closes the queue; calling it again is harmless.

send

@ExperimentalLiveApi

fun send(request: LiveRequest)

Sends request; a LiveRequest.close request delivers its LiveRequest.stateDelta, then closes the queue.

sendActivityEnd

@ExperimentalLiveApi

fun sendActivityEnd()

Marks the end of user activity, when automatic activity detection is disabled.

sendActivityStart

@ExperimentalLiveApi

fun sendActivityStart()

Marks the start of user activity, when automatic activity detection is disabled.

sendAudioStreamEnd

@ExperimentalLiveApi

fun sendAudioStreamEnd()

Marks the end of the audio stream, forcing the model to flush what it has.

sendContent

@JvmOverloads

@ExperimentalLiveApi

fun sendContent(content: Content, partial: Boolean = false)

Sends content in turn-by-turn mode.

sendRealtime

@ExperimentalLiveApi

fun sendRealtime(input: RealtimeInput)

Sends a RealtimeInput.Audio chunk, a RealtimeInput.Video frame, or an activity signal in realtime mode.