Package com.google.adk.agents

Class LiveRequestQueue

java.lang.Object

com.google.adk.agents.LiveRequestQueue

public final class LiveRequestQueue
extends Object

A queue of live requests to be sent to the model.

Constructor Summary

Constructors

Constructor	Description
LiveRequestQueue()

Method Summary

Modifier and Type	Method	Description
void	close()
void	content(com.google.genai.types.Content content)
void	content(com.google.genai.types.Content content, boolean partial)	Sends content to the model, optionally as a partial update that leaves the current turn open.
io.reactivex.rxjava3.core.Flowable<LiveRequest>	get()
void	realtime(com.google.genai.types.Blob blob)
void	send(LiveRequest request)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LiveRequestQueue

public LiveRequestQueue()

Method Details

close

public void close()

content

public void content(com.google.genai.types.Content content)

content

public void content(com.google.genai.types.Content content,
 boolean partial)

Sends content to the model, optionally as a partial update that leaves the current turn open.

Parameters:

content - the content to send

partial - whether this content is a partial update that does not complete the current turn

realtime

public void realtime(com.google.genai.types.Blob blob)

send

public void send(LiveRequest request)

get

public io.reactivex.rxjava3.core.Flowable<LiveRequest> get()