Struct MockProvider 

pub struct MockProvider { /* private fields */ }

A queue-based mock provider for unit and integration tests.

Push responses with queue_response and errors with queue_error. Each call to generate or stream pops from the front of the respective queue.

Every call records its ChatParams for later assertion via recorded_calls.

Panics

generate panics if the response queue is empty. stream panics if the stream queue is empty.

Implementations

impl MockProvider

pub fn new(meta: ProviderMetadata) -> Self

Creates a new mock with the given metadata and empty queues.

pub fn queue_response(&self, response: ChatResponse) -> &Self

Enqueues a successful response for the next generate call.

pub fn queue_error(&self, error: MockError) -> &Self

Enqueues an error for the next generate call.

pub fn queue_stream(&self, events: Vec<StreamEvent>) -> &Self

Enqueues stream events for the next stream call.

pub fn queue_stream_error(&self, error: MockError) -> &Self

Enqueues an error for the next stream call.

The error is returned from stream() itself (before any events are yielded), simulating failures like authentication errors or network issues that prevent the stream from starting.

pub fn recorded_calls(&self) -> Vec<ChatParams>

Returns a clone of all ChatParams passed to generate or stream, in call order.

Trait Implementations

impl Debug for MockProvider

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Provider for MockProvider

async fn generate(&self, params: &ChatParams) -> Result<ChatResponse, LlmError>

Sends a chat completion request and returns the full response.

async fn stream(&self, params: &ChatParams) -> Result<ChatStream, LlmError>

Sends a chat completion request and returns a stream of events.

fn metadata(&self) -> ProviderMetadata

Returns static metadata describing this provider instance.