diff options
| author | Matthias Beyer <mail@beyermatthias.de> | 2024-03-28 09:57:55 +0100 |
|---|---|---|
| committer | Matthias Beyer <mail@beyermatthias.de> | 2024-03-28 10:05:22 +0100 |
| commit | dedbb44642232a331925dd6230368629b7f56c7d (patch) | |
| tree | aaa7221858d385ab684f58067c5c17e6e9fb151d | |
| parent | c45728d7af95f4dc876edcff004446fab56f43a5 (diff) | |
Fix: Make ReceiveMaximum use NonZeroU16
Signed-off-by: Matthias Beyer <mail@beyermatthias.de>
| -rw-r--r-- | src/packets/connack.rs | 2 | ||||
| -rw-r--r-- | src/packets/connect.rs | 2 | ||||
| -rw-r--r-- | 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(); |