Package com.google.genai

Class AsyncSession

java.lang.Object

com.google.genai.AsyncSession

public final class AsyncSession
extends Object

AsyncSession manages sending and receiving messages over a WebSocket connection for a live session. The live module is experimental.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	close()	Closes the WebSocket connection.
CompletableFuture<Void>	receive(Consumer<LiveServerMessage> onMessage)	Registers a callback to receive messages from the live session.
CompletableFuture<Void>	sendClientContent(LiveSendClientContentParameters clientContent)	Sends client content to the live session.
CompletableFuture<Void>	sendRealtimeInput(LiveSendRealtimeInputParameters realtimeInput)	Sends realtime input to the live session.
CompletableFuture<Void>	sendToolResponse(LiveSendToolResponseParameters toolResponse)	Sends tool response to the live session.

Methods inherited from class java.lang.Object

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

Method Details

sendClientContent

public CompletableFuture<Void> sendClientContent(LiveSendClientContentParameters clientContent)

Sends client content to the live session.

Parameters:

clientContent - A LiveSendClientContentParameters to send.

Returns:

A CompletableFuture that completes when the client content has been sent. The future will fail if the client content cannot be sent.

sendRealtimeInput

public CompletableFuture<Void> sendRealtimeInput(LiveSendRealtimeInputParameters realtimeInput)

Sends realtime input to the live session.

Parameters:

realtimeInput - A LiveSendRealtimeInputParameters to send.

Returns:

A CompletableFuture that completes when the realtime input has been sent. The future will fail if the realtime input cannot be sent.

sendToolResponse

public CompletableFuture<Void> sendToolResponse(LiveSendToolResponseParameters toolResponse)

Sends tool response to the live session.

Parameters:

toolResponse - A LiveSendToolResponseParameters to send.

Returns:

A CompletableFuture that completes when the tool response has been sent. The future will fail if the tool response cannot be sent.

receive

public CompletableFuture<Void> receive(Consumer<LiveServerMessage> onMessage)

Registers a callback to receive messages from the live session. Only one callback can be registered at a time.

Parameters:

onMessage - A Consumer that will be called for each LiveServerMessage received.

Returns:

A CompletableFuture that completes when the callback has been registered. Note: This future doesn't represent the entire lifecycle of receiving messages, just the *registration* of the callback.

close

public CompletableFuture<Void> close()

Closes the WebSocket connection.

Returns:

A CompletableFuture that completes when the connection has been closed.