Skip to main content

mqttbytes_core/
ping.rs

1use bytes::{BufMut, BytesMut};
2
3pub const PINGREQ_FRAME: [u8; 2] = [0xC0, 0x00];
4pub const PINGRESP_FRAME: [u8; 2] = [0xD0, 0x00];
5
6#[must_use]
7pub fn write_pingreq(payload: &mut BytesMut) -> usize {
8    payload.put_slice(&PINGREQ_FRAME);
9    PINGREQ_FRAME.len()
10}
11
12#[must_use]
13pub fn write_pingresp(payload: &mut BytesMut) -> usize {
14    payload.put_slice(&PINGRESP_FRAME);
15    PINGRESP_FRAME.len()
16}