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

BasePublisherModel

abstract class BasePublisherModel(val name: String) : Model

Java-friendly base for implementing a Model. A Java subclass overrides generateContentJava, which returns a Reactive Streams Publisher; this base adapts it to the Flow-returning generateContent contract that Java cannot express. Both the unary and streaming cases flow through that one method, exactly as they do for a Kotlin Model; a subclass that supports live connections also overrides connectAsync.

Constructors

BasePublisherModel

constructor(name: String)

Properties

name

override val name: String

The name of the model.

Functions

connect

suspend override fun connect(request: LlmRequest): LiveConnection

Opens a live (bidirectional streaming) connection, configured by LlmRequest.liveConnectConfig.

generateContent

override fun generateContent(request: LlmRequest, stream: Boolean = false): Flow<LlmResponse>

Generates content for the given LlmRequest. This returns a Flow of LlmResponses.