Struct ProtobufDecoder 

pub struct ProtobufDecoder<T> { /* private fields */ }

Protobuf 消息解码器，支持粘包处理

Implementations

impl<T> ProtobufDecoder<T>

where T: Message + Default,

pub fn new() -> Self

创建新的解码器

pub fn add_data(&mut self, data: &[u8])

向解码器添加数据（处理粘包）

pub fn decode_next(&mut self) -> Result<Option<T>, Box<dyn Error + Send + Sync>>

解码下一个完整的消息

返回 Ok(Some(message)) 如果有足够的数据解码一个完整的消息 返回 Ok(None) 如果数据不足（需要更多数据） 返回 Err 如果解码失败

pub fn has_remaining(&self) -> bool

检查是否还有未处理的数据

pub fn remaining_len(&self) -> usize

获取剩余数据长度

pub fn clear(&mut self)

清空缓冲区

Trait Implementations

impl<T> Default for ProtobufDecoder<T>

where T: Message + Default,

fn default() -> Self

Returns the “default value” for a type.