We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cfebe7b commit f7bc77eCopy full SHA for f7bc77e
1 file changed
src/mqtt_client/engine.rs
@@ -916,9 +916,12 @@ impl QuicMqttEngine {
916
transport.datagram_receive_buffer_size(None);
917
// Set max_idle_timeout to prevent QUIC from timing out before MQTT keepalive mechanism
918
// Use 120 seconds to accommodate MQTT keepalive (typically 30-60s) with 2x multiplier for safety
919
- transport.max_idle_timeout(Some(
920
- std::time::Duration::from_secs(120).try_into().unwrap(),
921
- ));
+ let idle_timeout = std::time::Duration::from_secs(120)
+ .try_into()
+ .map_err(|e| MqttClientError::InternalError {
922
+ message: format!("Failed to convert QUIC idle timeout: {}", e),
923
+ })?;
924
+ transport.max_idle_timeout(Some(idle_timeout));
925
client_config.transport_config(Arc::new(transport));
926
927
let (ch, conn) = self
0 commit comments