Struct CompressionMiddleware 

pub struct CompressionMiddleware { /* private fields */ }

Compression middleware for reducing message size.

Implementations

impl CompressionMiddleware

pub fn new(compression_type: CompressionType, min_size: usize) -> Self

Create a new compression middleware.

Trait Implementations

impl AdvancedMiddleware for CompressionMiddleware

fn name(&self) -> &'static str

Get middleware name for identification

fn priority(&self) -> MiddlewarePriority

Get middleware priority for execution ordering

fn on_send_with_context<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, message: &'life1 TransportMessage, context: &'life2 MiddlewareContext, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when a message is sent with context.

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

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

Check if middleware should be executed for this context

fn on_request_with_context<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, request: &'life1 mut JSONRPCRequest, context: &'life2 MiddlewareContext, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called before a request is sent with context.

fn on_response_with_context<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, response: &'life1 mut JSONRPCResponse, context: &'life2 MiddlewareContext, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called after a response is received with context.

fn on_receive_with_context<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, message: &'life1 TransportMessage, context: &'life2 MiddlewareContext, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when a message is received with context.

fn on_notification_with_context<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, notification: &'life1 mut JSONRPCNotification, context: &'life2 MiddlewareContext, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when an unsolicited notification is received with context.

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

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

Called when middleware chain starts

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

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

Called when middleware chain completes

fn on_error<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _error: &'life1 Error, _context: &'life2 MiddlewareContext, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when an error occurs in the chain

impl Debug for CompressionMiddleware

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.