Struct InputProcessorPipeline 

pub struct InputProcessorPipeline { /* private fields */ }

Input Processor Pipeline - chains multiple processors

Implementations

impl InputProcessorPipeline

pub fn new() -> Self

Create a new empty pipeline

pub fn add(self, processor: Arc<dyn InputProcessor>) -> Self

Add a processor to the pipeline

pub async fn process( &self, input: &str, ctx: &PolicyContext, ) -> Result<InputProcessorResult>

Run all processors in sequence

Processing stops on first Block. Modify results are chained (each processor sees the modified input).

pub fn is_empty(&self) -> bool

Check if the pipeline is empty

pub fn len(&self) -> usize

Get the number of processors

Trait Implementations

impl Default for InputProcessorPipeline

fn default() -> Self

Returns the “default value” for a type.