Struct MiddlewareChain 

pub struct MiddlewareChain {
    pub middlewares: Vec<Arc<dyn Middleware>>,
    pub handler: Option<Arc<dyn Handler>>,
}

Middleware chain holds all middlewares and the final handler.

The chain executes middleware in the order they were added, and finally calls the handler if all middleware pass control forward.

Examples

use wsforge::prelude::*;

let mut chain = MiddlewareChain::new();

// Add middleware
chain.layer(LoggerMiddleware::new());

// Set final handler
chain.handler(handler(my_handler));

Fields

middlewares: Vec<Arc<dyn Middleware>>

All middleware in the chain, executed in order

handler: Option<Arc<dyn Handler>>

The final handler to call after all middleware

Implementations

impl MiddlewareChain

pub fn new() -> MiddlewareChain

Creates a new empty middleware chain.

Examples

use wsforge::prelude::*;

let chain = MiddlewareChain::new();

pub fn layer(self, middleware: Arc<dyn Middleware>) -> MiddlewareChain

Add a middleware to the chain.

Middleware are executed in the order they are added.

Arguments

• middleware - The middleware to add

Examples

use wsforge::prelude::*;

let mut chain = MiddlewareChain::new();

chain.layer(LoggerMiddleware::new());

pub fn handler(self, handler: Arc<dyn Handler>) -> MiddlewareChain

Set the final handler for the chain.

The handler is called after all middleware have been executed.

Arguments

• handler - The handler to call

Examples

use wsforge::prelude::*;

async fn my_handler(msg: Message) -> Result<String> {
    Ok("response".to_string())
}

let mut chain = MiddlewareChain::new();
chain.handler(handler(my_handler));

pub async fn execute( &self, message: Message, conn: Connection, state: AppState, extensions: Extensions, ) -> Result<Option<Message>, Error>

Execute the middleware chain.

This runs all middleware in order, then calls the handler if present.

Arguments

• message - The message to process
• conn - The connection
• state - Application state
• extensions - Extension data

Examples

use wsforge::prelude::*;

let state = AppState::new();
let extensions = Extensions::new();

let response = chain.execute(msg, conn, state, extensions).await?;

Trait Implementations

impl Clone for MiddlewareChain

fn clone(&self) -> MiddlewareChain

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MiddlewareChain

fn default() -> MiddlewareChain

Returns the “default value” for a type.