fix: panic if max_inflight == u16::MAX

Devdutt Shenoi · Devdutt Shenoi · commit 4a936fedde6c · 2024-09-30T01:36:06.000+05:30
diff --git a/rumqttc/src/state.rs b/rumqttc/src/state.rs
@@ -98,7 +98,7 @@ impl MqttState {
             // TODO: Optimize these sizes later
             events: VecDeque::with_capacity(100),
             manual_acks,
-            ack_waiter: (0..max_inflight + 1).map(|_| None).collect(),
+            ack_waiter: (0..max_inflight as usize + 1).map(|_| None).collect(),
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -98,7 +98,7 @@ impl MqttState {`
`98`	`98`	`// TODO: Optimize these sizes later`
`99`	`99`	`events: VecDeque::with_capacity(100),`
`100`	`100`	`manual_acks,`
`101`		`- ack_waiter: (0..max_inflight + 1).map(\|_\| None).collect(),`
	`101`	`+ ack_waiter: (0..max_inflight as usize + 1).map(\|_\| None).collect(),`
`102`	`102`	`}`
`103`	`103`	`}`
`104`	`104`