Embabel Agent Documentation/com.embabel.agent.api.common.streaming/StreamingPromptRunnerOperations

StreamingPromptRunnerOperations

interface StreamingPromptRunnerOperations : StreamingCapability

Streaming operations interface providing fluent API for configuring and executing streaming prompts. Follows the same pattern as PromptRunnerOperations but returns reactive streams instead of blocking results.

Extends StreamingCapability to enable polymorphic access through the tag interface.

Functions

createObjectStream

abstract fun <T> createObjectStream(itemClass: Class<T>): <Error class: unknown class><T>

Create a reactive stream of objects of the specified type. Objects are emitted as they become available during LLM processing.

createObjectStreamWithThinking

abstract fun <T> createObjectStreamWithThinking(itemClass: Class<T>): <Error class: unknown class><<Error class: unknown class><T>>

Create a reactive stream with both objects and thinking content. Provides access to the LLM's reasoning process alongside the results.

withMessages

abstract fun withMessages(messages: List<Message>): StreamingPromptRunnerOperations

Configure the streaming operation with a list of messages.

withPrompt

abstract fun withPrompt(prompt: String): StreamingPromptRunnerOperations

Configure the streaming operation with a single prompt message.