rocketmq_common::common::message::message_decoder

Function decodes_batch_client

Source 
pub fn decodes_batch_client(
    byte_buffer: &mut Bytes,
    read_body: bool,
    decompress_body: bool,
) -> Vec<MessageClientExt>