Struct CompressedProtocol 

pub struct CompressedProtocol { /* private fields */ }

WebSocket protocol handler with permessage-deflate compression (RFC 7692)

Implementations

impl CompressedProtocol

pub fn server( max_frame_size: usize, max_message_size: usize, config: DeflateConfig, ) -> Self

Create a new compressed protocol handler for server role

pub fn client( max_frame_size: usize, max_message_size: usize, config: DeflateConfig, ) -> Self

Create a new compressed protocol handler for client role

pub fn is_closed(&self) -> bool

Check if connection is closed

pub fn is_closing(&self) -> bool

Check if we’re in the closing handshake

pub fn process(&mut self, buf: &mut BytesMut) -> Result<Vec<Message>>

Process incoming data and return complete messages

pub fn process_into( &mut self, buf: &mut BytesMut, messages: &mut Vec<Message>, ) -> Result<()>

Process incoming data into a reusable message buffer

pub fn encode_message( &mut self, msg: &Message, buf: &mut BytesMut, ) -> Result<()>

Encode a message for sending with compression

pub fn encode_pong(&mut self, ping_data: &[u8], buf: &mut BytesMut)

Encode a pong response for a ping

pub fn encode_close_response(&mut self, buf: &mut BytesMut)

Encode a close response

pub fn split( self, max_frame_size: usize, max_message_size: usize, ) -> (CompressedReaderProtocol, CompressedWriterProtocol)

Split the compressed protocol into separate reader and writer halves

This allows the encoder and decoder to be used independently for concurrent read/write operations.