pulsar-binary-protocol-spec 0.0.1

Pulsar binary protocol specification
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

make_x_id_builder_and_x_id!(RequestId);

impl RequestId {
    pub fn is_require_set(&self) -> bool {
        self.0 == 0
    }
}

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

    #[test]
    fn simple() {
        let builder = RequestIdBuilder::new(None);
        assert_eq!(u64::from(builder.next()), 1);
        assert_eq!(u64::from(builder.next()), 2);

        let builder = RequestIdBuilder::new(11);
        assert_eq!(u64::from(builder.next()), 11);
        assert_eq!(u64::from(builder.next()), 12);
    }
}