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

StreamingPromptRunnerOperations

interface ~~StreamingPromptRunnerOperations~~ : StreamingPromptRunner.Streaming

Deprecated

Use StreamingPromptRunner.Streaming instead

Replace with

import com.embabel.agent.api.common.StreamingPromptRunner.Streaming

StreamingPromptRunner.Streaming

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.

generateStream

abstract fun generateStream(): <Error class: unknown class><String>

Generate a reactive stream of text chunks as they arrive from the LLM.

withMessages

abstract fun withMessages(messages: List<Message>): StreamingPromptRunner.Streaming

Configure the streaming operation with a list of messages.

withPrompt

abstract fun withPrompt(prompt: String): StreamingPromptRunner.Streaming

Configure the streaming operation with a single prompt message.