Struct StrOutputParser 

pub struct StrOutputParser;

字符串输出解析器

最简单的解析器，直接将 LLM 输出作为字符串返回。 相当于 Python LangChain 的 StrOutputParser。

作为 Runnable 时接收 LLMResult，取其 content 字段后原样返回， 使 llm.pipe(StrOutputParser) 成为 LCEL 链的尾段。

示例

use langchainrust::output_parsers::StrOutputParser;

let parser = StrOutputParser::new();
let result = parser.parse("Hello, world!").await?;
assert_eq!(result, "Hello, world!");

Implementations

impl StrOutputParser

pub fn new() -> Self

创建字符串输出解析器。

Trait Implementations

impl BaseOutputParser<String> for StrOutputParser

fn parse<'life0, 'life1, 'async_trait>( &'life0 self, text: &'life1 str, ) -> Pin<Box<dyn Future<Output = OutputParserResult<String>> + Send + 'async_trait>>

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

将原始 LLM 输出文本解析为目标类型

fn parse_with_retry<'life0, 'life1, 'async_trait>( &'life0 self, text: &'life1 str, max_retries: usize, ) -> Pin<Box<dyn Future<Output = OutputParserResult<Output>> + Send + 'async_trait>>

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

带重试的解析（默认实现：真正重试 max_retries 次）

fn get_format_instructions(&self) -> String

获取格式指令（用于提示 LLM 按指定格式输出）

impl Default for StrOutputParser

fn default() -> Self

Returns the “default value” for a type.

impl Runnable<LLMResult, String> for StrOutputParser

type Error = OutputParserError

Error type.

fn invoke<'life0, 'async_trait>( &'life0 self, input: LLMResult, _config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<String, Self::Error>> + Send + 'async_trait>>

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

Transforms single input to output.

fn stream<'life0, 'async_trait>( &'life0 self, input: LLMResult, _config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<String, Self::Error>> + Send>>, Self::Error>> + Send + 'async_trait>>

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

Streaming output - for real-time responses (LLM, etc).

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

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

Batch processing - transforms multiple inputs to outputs.

fn batch_as_completed<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Vec<(usize, Output)>, Self::Error>> + Send + 'async_trait>>

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

Batch processing that returns results in completion order.

fn transform<'life0, 'async_trait>( &'life0 self, input: Pin<Box<dyn Stream<Item = Result<Input, Self::Error>> + Send>>, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<Output, Self::Error>> + Send + '_>>, Self::Error>> + Send + 'async_trait>>

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

Stream-to-stream transformation - the core of LCEL streaming.