Struct JsonOutputParser 

pub struct JsonOutputParser<T> { /* private fields */ }

Parses an assistant Message as JSON into T.

The parser concatenates every ContentPart::Text in the message and runs serde_json::from_str on the result. Non-text parts are ignored; callers that need stricter handling can wrap this with a crate::RunnableLambda preprocessor.

use entelix_runnable::JsonOutputParser;
use serde::Deserialize;

#[derive(Deserialize)]
struct Reply { answer: String }

let parser = JsonOutputParser::<Reply>::new();
let chain = prompt.pipe(model).pipe(parser);

Implementations

impl<T> JsonOutputParser<T>

pub const fn new() -> Self

Build a fresh parser. Consumers usually let type inference at the call site pin T.

Trait Implementations

impl<T> Clone for JsonOutputParser<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Default for JsonOutputParser<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> Runnable<Message, T> for JsonOutputParser<T>

where T: DeserializeOwned + Send + 'static,

fn invoke<'life0, 'life1, 'async_trait>( &'life0 self, input: Message, _ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<T>> + 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").

impl<T> Copy for JsonOutputParser<T>