Struct TestingMiddleware 

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

A testing middleware that tracks connection statistics using the shared StatisticsTracker

Implementations

impl<S: AppState> TestingMiddleware<S>

pub fn new(stats: Arc<StatisticsTracker>) -> Self

Create a new testing middleware with the provided StatisticsTracker

Trait Implementations

impl<S: AppState> WebSocketMiddleware<S> for TestingMiddleware<S>

fn on_connection_attempt<'life0, 'life1, 'async_trait>( &'life0 self, _context: &'life1 MiddlewareContext<S>, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when a connection attempt is made (before actual connection)

fn on_connection_failure<'life0, 'life1, 'async_trait>( &'life0 self, _context: &'life1 MiddlewareContext<S>, reason: Option<String>, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when a connection attempt fails

fn on_connect<'life0, 'life1, 'async_trait>( &'life0 self, _context: &'life1 MiddlewareContext<S>, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when a WebSocket connection is established.

fn on_disconnect<'life0, 'life1, 'async_trait>( &'life0 self, _context: &'life1 MiddlewareContext<S>, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when a WebSocket connection is lost.

fn on_send<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, message: &'life1 Message, _context: &'life2 MiddlewareContext<S>, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called before a message is sent to the WebSocket.

fn on_receive<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, message: &'life1 Message, _context: &'life2 MiddlewareContext<S>, ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called after a message is received from the WebSocket.