rzmq 0.5.25

High performance, CPU and memory efficient, fully asynchronous, safe pure-Rust implementation of ZeroMQ (ØMQ) messaging with io_uring and TCP Cork acceleration on Linux.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

use bitflags::bitflags;

bitflags! {
    /// Flags associated with a `Msg` indicating its role or attributes.
    #[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Default)]
    pub struct MsgFlags: u8 {
        /// More message parts follow this one.
        const MORE = 0b01;
        /// Internal: Indicates a ZMTP command frame.
        const COMMAND = 0b10;
        // Add other flags later if needed
    }
}

#[cfg(test)]
mod additional_flags_tests {
  use super::*;

  #[test]
  fn test_flags_bitwise_operations() {
    let more_flag = MsgFlags::MORE;
    let cmd_flag = MsgFlags::COMMAND;

    let combined = more_flag | cmd_flag;
    assert!(combined.contains(MsgFlags::MORE));
    assert!(combined.contains(MsgFlags::COMMAND));

    let intersection = combined & MsgFlags::MORE;
    assert!(intersection.contains(MsgFlags::MORE));
    assert!(!intersection.contains(MsgFlags::COMMAND));

    let difference = combined - MsgFlags::MORE;
    assert!(!difference.contains(MsgFlags::MORE));
    assert!(difference.contains(MsgFlags::COMMAND));
  }
}