google-adk-kotlin-core/com.google.adk.kt.interop/PublisherRunner

PublisherRunner

Java-friendly wrapper around a Runner. A run is exposed as a Reactive Streams Publisher of events, so Java callers never touch Flow; collect it with AsyncJavaHelpers.collect/forEach or any Reactive Streams consumer. Session management is not a runner concern -- reach the session service via asKotlinRunner().sessionService (or wrap it in a BaseFutureSessionService).

Types

Companion

object Companion

Properties

appName

val appName: String

Functions

asKotlinRunner

fun asKotlinRunner(): Runner

The wrapped engine runner, for code that has dropped into Kotlin.

open override fun close()

rewindAsync

fun rewindAsync(userId: String, sessionId: String, rewindBeforeInvocationId: String): CompletableFuture<Void?>

Rewinds the session to before rewindBeforeInvocationId; see Runner.rewindAsync. The returned future completes once the rewind has been applied.

runAsync

fun runAsync(userId: String, sessionId: String, invocationId: String? = null, newMessage: Content? = null, stateDelta: Map<String, Any>? = null, runConfig: RunConfig? = null): Publisher<Event>

Runs the agent, streaming its events. Set invocationId to resume an interrupted invocation.