Set next_incoming_id for Flow frame (#57)

Author: fafhrd91

CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [3.1.0] - 2024-12-01
+
+* Set "next_incoming_id" for Flow frame
+
 ## [3.0.4] - 2024-09-17
 
 * Use derive_more 1.0

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-amqp"
-version = "3.0.4"
+version = "3.1.0"
 authors = ["ntex contributors <[email protected]>"]
 description = "AMQP 1.0 Client/Server framework"
 documentation = "https://docs.rs/ntex-amqp"

src/session.rs

@@ -1188,11 +1188,7 @@ impl SessionInner {
 
     pub(crate) fn rcv_link_flow(&mut self, handle: u32, delivery_count: u32, credit: u32) {
         let flow = Flow(Box::new(codec::FlowInner {
-            next_incoming_id: if self.flags.contains(Flags::LOCAL) {
-                Some(self.next_incoming_id)
-            } else {
-                None
-            },
+            next_incoming_id: Some(self.next_incoming_id),
             incoming_window: u32::MAX,
             next_outgoing_id: self.next_outgoing_id,
             outgoing_window: self.remote_incoming_window,