Struct ScriptedModel 

pub struct ScriptedModel { /* private fields */ }

Replays queued responses in order and streams each response’s text as one delta. An exhausted script fails the request with a decode-style LlmError so a test never hangs on a missing response.

Implementations

impl ScriptedModel

pub fn new( responses: impl IntoIterator<Item = Result<CompletionResponse, LlmError>>, ) -> Self

Model that replays responses in order.

pub fn replies(messages: impl IntoIterator<Item = ChatMessage>) -> Self

Script one assistant reply per message, each finishing with stop (or tool_calls when the message carries tool calls).

pub fn response(message: ChatMessage) -> CompletionResponse

Build a canonical single-choice response for message.

pub fn remaining(&self) -> usize

Responses still queued.

pub fn requests(&self) -> Vec<CompletionRequest>

Every request the runtime sent, in order.

Trait Implementations

impl ChatModel for ScriptedModel

fn complete_streaming<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 CompletionRequest, delta_tx: UnboundedSender<(String, bool)>, ) -> Pin<Box<dyn Future<Output = Result<CompletionResponse, LlmError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stream cumulative (content, has_tool_calls) updates and return the canonical terminal response. This is the only model invocation path.

impl Default for ScriptedModel

fn default() -> ScriptedModel

Returns the “default value” for a type.