Struct CompressedReaderProtocol 

pub struct CompressedReaderProtocol { /* private fields */ }

Reader half of a split compressed protocol

Contains the decoder and frame parser for reading compressed messages.

Implementations

impl CompressedReaderProtocol

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

Create a new reader protocol for server role

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

Create a new reader protocol for client role

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