hebo_codec 0.2.3

Packet codec for MQTT protocol
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

// Copyright (c) 2022 Xu Shaohua <shaohua@biofan.org>. All rights reserved.
// Use of this source is governed by Apache-2.0 License that can be found
// in the LICENSE file.

#![allow(clippy::module_name_repetitions)]

use crate::{DecodeError, U16Data};

/// `KeepAlive` presents connection keep-alive time in milliseconds.
pub type KeepAlive = U16Data;

/// Check `keep_alive` is in range.
///
/// # Errors
///
/// Returns error if `keep_alive` value is too small.
pub const fn validate_keep_alive(keep_alive: KeepAlive) -> Result<(), DecodeError> {
    if keep_alive.value() != 0 && keep_alive.value() < 5 {
        Err(DecodeError::OtherErrors)
    } else {
        Ok(())
    }
}