Struct DataMessage 

pub struct DataMessage { /* private fields */ }

Zenoh-Flow data message.

It contains the actual data, the timestamp associated, the end to end deadline, the end to end deadline misses and loop contexts.

Implementations

impl DataMessage

pub fn new_serialized(data: Vec<u8>, timestamp: Timestamp) -> Self

Creates a new message from serialized data.

This is used when the message is coming from Zenoh or from a non-rust node.

pub fn get_timestamp(&self) -> &Timestamp

Return the Timestamp associated with this DataMessage.

Methods from Deref<Target = Payload>

pub fn try_as_bytes(&self) -> Result<Arc<Vec<u8>>>

Return an Arc containing the bytes representation of the Payload.

Performance

This method will only serialize (and thus allocate) the Payload if it is typed. Otherwise the Arc is cloned.

Trait Implementations

impl Clone for DataMessage

fn clone(&self) -> DataMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DataMessage

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

Formats the value using the given formatter.

impl Deref for DataMessage

type Target = Payload

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<'de> Deserialize<'de> for DataMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<DataMessage> for Payload

fn from(data_message: DataMessage) -> Self

Converts to this type from the input type.

impl Serialize for DataMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.