Struct LocalThreadRuntime 

pub struct LocalThreadRuntime { /* private fields */ }

A single thread with its branches, driving one model adapter.

Implementations

impl LocalThreadRuntime

pub fn new( adapter: impl ChatModelAdapter + 'static, options: LocalRuntimeOptions, ) -> Self

A runtime that runs adapter for each message sent.

pub fn subscribe(&self, callback: impl Fn() + 'static) -> Subscription

Called after every change. Drop the guard to unsubscribe.

pub fn messages(&self) -> Arc<[Arc<ThreadMessage>]>

The selected branch, root first. Cheap to call; cached between changes.

pub fn is_running(&self) -> bool

Whether a run is in progress.

pub fn message(&self, id: &MessageId) -> Result<MessageEntry, RuntimeError>

A message and its position, by id.

pub fn branches(&self, id: &MessageId) -> Result<Vec<MessageId>, RuntimeError>

The message and its siblings, for a branch picker.

pub fn switch_to_branch(&self, id: &MessageId) -> Result<(), RuntimeError>

Select the branch containing id; subscribers are notified.

pub fn composer(&self) -> Composer

The composer for the next message (thread.composer).

pub fn begin_edit(&self, id: &MessageId) -> Result<Composer, RuntimeError>

Start editing a message (beginEdit). Sending the edit composer adds a sibling branch; cancelling discards it.

pub fn edit_composer(&self, id: &MessageId) -> Option<Composer>

The edit composer for a message, while it is being edited.

pub fn set_tools(&self, tools: ToolRegistry)

Register the tools this thread offers. Their definitions are added to the model context (replacing earlier tool definitions), and open calls of tools with an execute function run in the app after each step.

pub fn respond_to_tool_approval( &self, message_id: &MessageId, approval_id: &str, approved: bool, reason: Option<String>, ) -> Result<Option<RunFuture>, RuntimeError>

Record the user’s answer to a pending tool approval (respond to a tool approval). An approved call runs; a denied one answers the model with an error. Returns the run that continues the message, if none is in progress, for the host to spawn.

pub fn set_model_context(&self, context: ModelContext)

Replace the system prompt, tools and settings sent with later runs.

pub fn submit_feedback( &self, id: &MessageId, feedback: Option<SubmittedFeedback>, ) -> Result<(), RuntimeError>

Record feedback on an assistant message (submitFeedback); None clears it.

pub fn export(&self) -> ExportedRepository

Persisted messages and the selected head.

pub fn import(&self, exported: ExportedRepository) -> Result<(), RuntimeError>

Load history (for example from a thread history adapter).

pub fn append(&self, message: AppendMessage) -> Result<RunFuture, RuntimeError>

Add a message. A user message (or start_run: Some(true)) starts a run answering it, cancelling any run in progress. Editing is an append with the edited message’s parent and source_id.

pub fn start_run( &self, config: StartRunConfig, ) -> Result<RunFuture, RuntimeError>

Add a running assistant message after parent_id and answer it: a new answer, or a regeneration when source_id names the previous one.

pub fn cancel_run(&self)

Cancel any run in progress; its message becomes incomplete/cancelled.

pub fn add_tool_result( &self, result: ToolResult, ) -> Result<Option<RunFuture>, RuntimeError>

Record a tool result. If that answers the last open call of a paused message, the run continues and its future is returned.

Trait Implementations

impl Clone for LocalThreadRuntime

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ThreadRuntime for LocalThreadRuntime

fn messages(&self) -> Arc<[Arc<ThreadMessage>]>

The selected branch, root first.

fn message(&self, id: &MessageId) -> Result<MessageEntry, RuntimeError>

A message and its position, by id.

fn is_running(&self) -> bool

Whether a run is in progress.

fn capabilities(&self) -> RuntimeCapabilities

What the UI may offer for this thread.

fn branches(&self, id: &MessageId) -> Result<Vec<MessageId>, RuntimeError>

The message and its siblings.

fn branch_position( &self, id: &MessageId, ) -> Result<(usize, usize), RuntimeError>

(position, count) of the message among its siblings, 1-based. The default builds branches; runtimes override it to avoid the allocation, which a UI pays once per message per update.

fn structure_version(&self) -> Option<u64>

A number that changes whenever branches or the selected path change, but not when a message is updated in place. While it is unchanged a UI may keep every message’s branch_position. None (the default) means unknown: positions must be read again.

fn message_changes_since(&self, version: Option<u64>) -> Option<MessageChanges>

Changed selected-message indices since a consumer’s last version. None (the default) means this runtime does not track changes: scan messages. A supported runtime returns a current version even when the journal requires a full read. Changes must cover every selected message update and be valid for the current messages() snapshot; versions are local to this runtime. Consumers must still refresh when running state or capabilities change.

fn switch_to_branch(&self, id: &MessageId) -> Result<(), RuntimeError>

Select the branch containing id.

fn append(&self, message: AppendMessage) -> Result<RunFuture, RuntimeError>

Add a message; a user message answers it (see AppendMessage).

fn reload(&self, config: StartRunConfig) -> Result<RunFuture, RuntimeError>

Answer parent_id again (regenerate).

fn cancel_run(&self)

Stop the run in progress, if any.

fn add_tool_result( &self, result: ToolResult, ) -> Result<Option<RunFuture>, RuntimeError>

Answer a tool call; may resume the run, which is then returned to spawn.

fn respond_to_tool_approval( &self, message_id: &MessageId, approval_id: &str, approved: bool, reason: Option<String>, ) -> Result<Option<RunFuture>, RuntimeError>

Approve or deny a pending tool approval; may resume the run, which is then returned to spawn.

fn submit_feedback( &self, id: &MessageId, feedback: Option<SubmittedFeedback>, ) -> Result<(), RuntimeError>

None clears feedback.

fn composer(&self) -> Composer

The composer for the next message.

fn begin_edit(&self, id: &MessageId) -> Result<Composer, RuntimeError>

Start editing a message and return its composer.

fn edit_composer(&self, id: &MessageId) -> Option<Composer>

The composer of a message being edited, if any.

fn subscribe_dyn(&self, callback: Box<dyn Fn()>) -> Subscription

Called after every change; drop the guard to unsubscribe.

fn export(&self) -> ExportedRepository

Persisted messages and the selected head.

fn import(&self, exported: ExportedRepository) -> Result<(), RuntimeError>

Load history.