Add Session::connection() method, return ref to Connection

ntex-rs · Aug 10, 2021 · 4705f2a · 4705f2a
1 parent 154f597
commit 4705f2a
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/CHANGES.md b/CHANGES.md
@@ -1,12 +1,14 @@
 # Changes
 
-## [0.5.0-b.3] - 2021-08-xx
+## [0.5.0-b.3] - 2021-08-10
+
+* Add Session::connection() method, returns ref to Connection
 
 * Add stream handling for transfer dispositions
 
 * Refactor sender link disposition handling
 
-## [codec-0.6.1] - 2021-08-0x
+## [codec-0.6.1] - 2021-08-10
 
 * Regenerate spec with inlines
 

diff --git a/Cargo.toml b/Cargo.toml
@@ -25,7 +25,7 @@ frame-trace = []
 
 [dependencies]
 ntex = "0.4.0-b.1"
-ntex-amqp-codec = "0.6.0"
+ntex-amqp-codec = "0.6.1"
 
 bitflags = "1.2"
 derive_more = "0.99"

diff --git a/src/session.rs b/src/session.rs
@@ -35,6 +35,10 @@ impl Session {
         Session { inner }
     }
 
+    pub fn connection(&self) -> &Connection {
+        &self.inner.get_ref().sink
+    }
+
     pub fn close(&self) -> impl Future<Output = Result<(), AmqpProtocolError>> {
         Ready::Ok(())
     }