Struct MessagePipeline 

pub struct MessagePipeline { /* private fields */ }

Message processing pipeline

Implementations

impl MessagePipeline

pub fn new() -> Self

Create a new empty pipeline

pub fn add(&mut self, middleware: Box<dyn Middleware>)

Add a middleware to the pipeline

pub fn process(&self, message: Message) -> Result<Message, MiddlewareError>

Process a message through the pipeline

pub fn len(&self) -> usize

Get the number of middlewares in the pipeline

pub fn is_empty(&self) -> bool

Check if the pipeline is empty

pub fn clear(&mut self)

Clear all middlewares

Trait Implementations

impl Default for MessagePipeline

fn default() -> Self

Returns the “default value” for a type.