Skip to main content

rumqttc/mqttbytes/v5/
ping.rs

1use super::Error;
2use bytes::BytesMut;
3
4#[derive(Debug, Clone, PartialEq, Eq)]
5pub struct PingReq;
6
7impl PingReq {
8    pub fn write(payload: &mut BytesMut) -> Result<usize, Error> {
9        Ok(mqttbytes_core::ping::write_pingreq(payload))
10    }
11
12    #[must_use]
13    pub const fn size(&self) -> usize {
14        2
15    }
16}
17
18#[derive(Debug, Clone, PartialEq, Eq)]
19pub struct PingResp;
20
21impl PingResp {
22    pub fn write(payload: &mut BytesMut) -> Result<usize, Error> {
23        Ok(mqttbytes_core::ping::write_pingresp(payload))
24    }
25
26    #[must_use]
27    pub const fn size(&self) -> usize {
28        2
29    }
30}