Struct MiddlewareStack 

pub struct MiddlewareStack<S: AppState> { /* private fields */ }

A composable stack of middleware layers.

This struct holds a collection of middleware that will be executed in order. Middleware are executed in the order they are added to the stack.

Example

use binary_options_tools_core_pre::middleware::MiddlewareStack;

let mut stack = MiddlewareStack::new();
stack.add_layer(Box::new(LoggingMiddleware));
stack.add_layer(Box::new(StatisticsMiddleware::new()));

Implementations

impl<S: AppState> MiddlewareStack<S>

pub fn new() -> Self

Creates a new empty middleware stack.

pub fn add_layer( &mut self, middleware: Box<dyn WebSocketMiddleware<S> + Send + Sync>, )

Adds a middleware layer to the stack.

Middleware will be executed in the order they are added.

pub async fn on_send(&self, message: &Message, context: &MiddlewareContext<S>)

Executes all middleware for an outgoing message.

Arguments

• message: The message being sent
• context: Context information

Behavior

All middleware will be executed even if some fail. Errors are logged but do not prevent other middleware from running.

pub async fn on_receive( &self, message: &Message, context: &MiddlewareContext<S>, )

Executes all middleware for an incoming message.

Arguments

• message: The message that was received
• context: Context information

Behavior

All middleware will be executed even if some fail. Errors are logged but do not prevent other middleware from running.

pub async fn on_connect(&self, context: &MiddlewareContext<S>)

Executes all middleware for connection establishment.

Arguments

• context: Context information

Behavior

All middleware will be executed even if some fail. Errors are logged but do not prevent other middleware from running.

pub async fn on_disconnect(&self, context: &MiddlewareContext<S>)

Executes all middleware for connection loss.

Arguments

• context: Context information

Behavior

All middleware will be executed even if some fail. Errors are logged but do not prevent other middleware from running.

pub async fn record_connection_attempt(&self, context: &MiddlewareContext<S>)

Record a connection attempt across all middleware

pub async fn record_connection_failure( &self, context: &MiddlewareContext<S>, reason: Option<String>, )

Record a connection failure across all middleware

pub fn len(&self) -> usize

Returns the number of middleware layers in the stack.

pub fn is_empty(&self) -> bool

Returns true if the stack is empty.

Trait Implementations

impl<S: AppState> Default for MiddlewareStack<S>

fn default() -> Self

Returns the “default value” for a type.