Struct OutputFixingParser 

pub struct OutputFixingParser<L, P> { /* private fields */ }

A parser/chain that wraps an LLM and a base parser. It attempts to invoke the LLM and parse the result. If parsing fails, it feeds the error back to the LLM to generate a fix.

Implementations

impl<L, P> OutputFixingParser<L, P>

pub fn new(llm: L, parser: P, max_retries: usize) -> Self

Trait Implementations

impl<L: Clone, P: Clone> Clone for OutputFixingParser<L, P>

fn clone(&self) -> OutputFixingParser<L, P>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<L, P, O> Runnable<LlmRequest, O> for OutputFixingParser<L, P>

where L: Runnable<LlmRequest, LlmResponse> + Clone + Send + Sync, P: Runnable<LlmResponse, O> + Clone + Send + Sync, O: Send + Sync + 'static,

fn invoke<'life0, 'async_trait>( &'life0 self, input: LlmRequest, ) -> Pin<Box<dyn Future<Output = Result<O, WesichainError>> + Send + 'async_trait>>

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

fn stream( &self, input: LlmRequest, ) -> BoxStream<'_, Result<StreamEvent, WesichainError>>

fn to_serializable(&self) -> Option<SerializableRunnable>

fn batch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, ) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>

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

fn abatch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, ) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>

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