Struct StructuredOutputAdapter 

pub struct StructuredOutputAdapter<O, C: Codec, T: Transport> { /* private fields */ }

Adapts a ChatModel<C, T> to Runnable<Vec<Message>, O> by routing every invoke through ChatModel::complete_typed::<O>.

O is constrained to the same trait set as complete_typed: schemars::JsonSchema + DeserializeOwned + Send + 'static. The validation-retry budget configured on the underlying ChatModel (ChatModelConfig::validation_retries) flows through unchanged — schema-mismatch retries reflect the parser diagnostic to the model and re-invoke (CLAUDE.md invariant 20).

Construct via Self::new (consumes the model), Self::from_arc (shares an existing Arc<ChatModel>), or — most ergonomic — via crate::ChatModelExt::with_structured_output.

Implementations

impl<O, C: Codec, T: Transport> StructuredOutputAdapter<O, C, T>

pub fn new(model: ChatModel<C, T>) -> Self

Wrap a concrete ChatModel.

pub const fn from_arc(model: Arc<ChatModel<C, T>>) -> Self

Wrap an already-shared Arc<ChatModel> — avoids a second Arc::new for operators that hold the model behind an Arc already.

pub const fn inner(&self) -> &Arc<ChatModel<C, T>>

Borrow the wrapped ChatModel — useful for inspecting config or threading the same model through multiple adapters.

Trait Implementations

impl<O, C: Codec, T: Transport> Clone for StructuredOutputAdapter<O, C, T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<O, C: Codec, T: Transport> Debug for StructuredOutputAdapter<O, C, T>

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

Formats the value using the given formatter.

impl<O, C, T> Runnable<Vec<Message>, O> for StructuredOutputAdapter<O, C, T>

where O: JsonSchema + DeserializeOwned + Send + 'static, C: Codec, T: Transport,

fn invoke<'life0, 'life1, 'async_trait>( &'life0 self, input: Vec<Message>, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<O>> + Send + 'async_trait>>

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

Single-shot invocation.

fn batch<'life0, 'life1, 'async_trait>( &'life0 self, inputs: Vec<I>, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<O>>> + Send + 'async_trait>>

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

Batch invocation. The default runs invoke sequentially over the input vector. Implementors that can parallelize (e.g. independent provider calls) override this.

fn stream<'life0, 'life1, 'async_trait>( &'life0 self, input: I, mode: StreamMode, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'_, Result<StreamChunk<O>>>>> + Send + 'async_trait>>

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

Streaming invocation, shaped by mode (see StreamMode).

fn name(&self) -> Cow<'_, str>

Human-readable identifier used by tracing and debug output. Default is the Rust type name — implementors may override with a domain label (e.g. "anthropic-messages", "json-parser").