From dedbb44642232a331925dd6230368629b7f56c7d Mon Sep 17 00:00:00 2001 From: Matthias Beyer Date: Thu, 28 Mar 2024 09:57:55 +0100 Subject: Fix: Make ReceiveMaximum use NonZeroU16 Signed-off-by: Matthias Beyer --- src/packets/connack.rs | 2 +- src/packets/connect.rs | 2 +- src/properties.rs | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/packets/connack.rs b/src/packets/connack.rs index f7f3a77..bf03113 100644 --- a/src/packets/connack.rs +++ b/src/packets/connack.rs @@ -12,7 +12,7 @@ crate::properties::define_properties! { session_expiry_interval: SessionExpiryInterval with setter = u32, (anker: "_Toc3901083") - receive_maximum: ReceiveMaximum with setter = u16, + receive_maximum: ReceiveMaximum with setter = core::num::NonZeroU16, (anker: "_Toc3901084") maximum_qos: MaximumQoS with setter = crate::v5::qos::QualityOfService, diff --git a/src/packets/connect.rs b/src/packets/connect.rs index ea0ac8c..79f57d2 100644 --- a/src/packets/connect.rs +++ b/src/packets/connect.rs @@ -12,7 +12,7 @@ crate::properties::define_properties! { session_expiry_interval: SessionExpiryInterval with setter = u32, (anker: "_Toc3901049") - receive_maximum: ReceiveMaximum with setter = u16, + receive_maximum: ReceiveMaximum with setter = core::num::NonZeroU16, (anker: "_Toc3901050") maximum_packet_size: MaximumPacketSize with setter = u32, diff --git a/src/properties.rs b/src/properties.rs index 6a7ff0b..2920b2c 100644 --- a/src/properties.rs +++ b/src/properties.rs @@ -163,7 +163,7 @@ define_property_types! {[ mqtt_format::v5::variable_header::ResponseInformation<'i> => inner = String; setter = String; outer ref = &'a str, mqtt_format::v5::variable_header::ServerReference<'i> => inner = String; setter = String; outer ref = &'a str, mqtt_format::v5::variable_header::ReasonString<'i> => inner = String; setter = String; outer ref = &'a str, - mqtt_format::v5::variable_header::ReceiveMaximum => inner = u16; setter = u16; outer deref = u16, + mqtt_format::v5::variable_header::ReceiveMaximum => inner = core::num::NonZeroU16; setter = core::num::NonZeroU16; outer deref = core::num::NonZeroU16, mqtt_format::v5::variable_header::TopicAliasMaximum => inner = u16; setter = u16; outer deref = u16, mqtt_format::v5::variable_header::TopicAlias => inner = u16; setter = u16; outer deref = u16, mqtt_format::v5::variable_header::MaximumQoS => inner = u8; setter = u8; outer deref = u8, @@ -198,7 +198,7 @@ mod tests { value: MqttString::from_str("bar").unwrap(), }); } - props.with_receive_maximum(4); + props.with_receive_maximum(std::num::NonZeroU16::new(4).unwrap()); let conn_props = props.as_ref(); -- cgit v1.2.3