From b653b98a91db466de2c005dffe803ebc5ddf641e Mon Sep 17 00:00:00 2001 From: Nikolay Kim Date: Sun, 1 Dec 2024 14:09:16 -0800 Subject: [PATCH] Set next_incoming_id for Flow frame --- CHANGES.md | 4 ++++ Cargo.toml | 2 +- src/session.rs | 6 +----- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/CHANGES.md b/CHANGES.md index 50507b0..a3b5a84 100644 --- a/CHANGES.md +++ b/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 diff --git a/Cargo.toml b/Cargo.toml index 059fa69..38c725e 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "ntex-amqp" -version = "3.0.4" +version = "3.1.0" authors = ["ntex contributors "] description = "AMQP 1.0 Client/Server framework" documentation = "https://docs.rs/ntex-amqp" diff --git a/src/session.rs b/src/session.rs index c24aa25..d373e9c 100644 --- a/src/session.rs +++ b/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,