Package dev.enola.ai.adk.core

Class UserSessionRunner

java.lang.Object

dev.enola.ai.adk.core.UserSessionRunner

All Implemented Interfaces:

AutoCloseable

public class UserSessionRunner
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
UserSessionRunner(String userId, com.google.adk.agents.BaseAgent agents)
UserSessionRunner(String userId, RunnersCache runnersService)
UserSessionRunner(String userId, String appName, RunnersCache runnersService)

Method Summary

Modifier and Type	Method	Description
void	close()
io.reactivex.rxjava3.core.Flowable<com.google.adk.events.Event>	runAsync(com.google.genai.types.Content newMessage)
io.reactivex.rxjava3.core.Flowable<com.google.adk.events.Event>	runAsync(com.google.genai.types.Content newMessage, com.google.adk.agents.RunConfig runConfig)
io.reactivex.rxjava3.core.Flowable<com.google.adk.events.Event>	runLive(com.google.adk.agents.LiveRequestQueue liveRequestQueue)
io.reactivex.rxjava3.core.Flowable<com.google.adk.events.Event>	runLive(com.google.adk.agents.LiveRequestQueue liveRequestQueue, com.google.adk.agents.RunConfig runConfig)

Methods inherited from class java.lang.Object

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

Constructor Details

UserSessionRunner

public UserSessionRunner(String userId,
 String appName,
 RunnersCache runnersService)

UserSessionRunner

public UserSessionRunner(String userId,
 RunnersCache runnersService)

UserSessionRunner

public UserSessionRunner(String userId,
 com.google.adk.agents.BaseAgent agents)

Method Details

runAsync

public io.reactivex.rxjava3.core.Flowable<com.google.adk.events.Event> runAsync(com.google.genai.types.Content newMessage,
 com.google.adk.agents.RunConfig runConfig)

runAsync

public io.reactivex.rxjava3.core.Flowable<com.google.adk.events.Event> runAsync(com.google.genai.types.Content newMessage)

runLive

public io.reactivex.rxjava3.core.Flowable<com.google.adk.events.Event> runLive(com.google.adk.agents.LiveRequestQueue liveRequestQueue,
 com.google.adk.agents.RunConfig runConfig)

runLive

public io.reactivex.rxjava3.core.Flowable<com.google.adk.events.Event> runLive(com.google.adk.agents.LiveRequestQueue liveRequestQueue)

close

public void close()

Specified by:

close in interface AutoCloseable