Struct BlockPipeline 

pub struct BlockPipeline { /* private fields */ }

Pipeline for processing blocks through multiple middleware stages

Example

use blocks::pipeline::BlockPipeline;

let pipeline = BlockPipeline::new()
    .add_middleware(|block| {
        block.content = block.content.trim().to_string();
        Ok(())
    })
    .add_middleware(|block| {
        block.content = block.content.to_uppercase();
        Ok(())
    });

Implementations

impl BlockPipeline

pub fn new() -> Self

Creates a new empty pipeline

pub fn with_name(name: impl Into<String>) -> Self

Creates a new pipeline with a name

pub fn add_middleware<F>(self, middleware: F) -> Self

where F: Fn(&mut Block) -> Result<()> + Send + Sync + 'static,

Adds a middleware function to the pipeline

pub fn process(&self, block: &mut Block) -> Result<()>

Processes a block through all middleware in the pipeline

pub fn process_all(&self, blocks: &mut [Block]) -> Result<()>

Processes multiple blocks through the pipeline

pub fn name(&self) -> &str

Returns the pipeline name

pub fn len(&self) -> usize

Returns the number of middleware in the pipeline

pub fn is_empty(&self) -> bool

Returns true if the pipeline is empty

Trait Implementations

impl Default for BlockPipeline

fn default() -> Self

Returns the “default value” for a type.