Struct Message 

pub struct Message { /* private fields */ }

Implementations

impl Message

pub fn new(seq: u32, topic: Bytes, payload: Bytes, compression_type: u8) -> Self

Creates a new message with the given sequence number, topic, and payload. If the payload is empty, the server will interpret this as a subscription toggle for the given topic. The timestamp is set to the current UNIX timestamp in microseconds.

Panics

Panics if the topic is larger than 65535 bytes.

pub fn new_sub(topic: Bytes) -> Self

Creates a new subscribe message for the given topic. The topic is prefixed with MSG.SUB..

pub fn new_unsub(topic: Bytes) -> Self

Creates a new unsubscribe message for the given topic. The topic is prefixed with MSG.UNSUB..

pub fn seq(&self) -> u32

pub fn payload_size(&self) -> u32

pub fn timestamp(&self) -> u64

pub fn size(&self) -> usize

pub fn payload(&self) -> &Bytes

pub fn into_payload(self) -> Bytes

pub fn into_parts(self) -> (Bytes, Bytes)

pub fn compression_type(&self) -> u8

pub fn topic(&self) -> &Bytes

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl Encoder<Message> for Codec

type Error = Error

The type of encoding errors.

fn encode( &mut self, item: Message, dst: &mut BytesMut, ) -> Result<(), Self::Error>

Encodes a frame into the buffer provided.