Merge branch 'lapin-0.26.x'

* lapin-0.26.x: v0.26.7 make IoLoop public drop async_await feature gate make more things public
amqp-rs · Aug 23, 2019 · 2b2627c · 2b2627c
2 parents 92cb6cd + cbb6da5
commit 2b2627c
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -11,6 +11,12 @@
 
 * Add support for `update_secret` for oauth2 authentication module
 
+### 0.26.7 (2019-08-23)
+
+#### Bug Fixes
+
+* Make `Connection::connector` and `IoLoop:run` public
+
 ### 0.26.6 (2019-08-15)
 
 #### Bug Fixes

diff --git a/src/connection.rs b/src/connection.rs
@@ -156,7 +156,7 @@ impl Connection {
         self.frames.drop_pending();
     }
 
-    fn connector(
+    pub fn connector(
         options: ConnectionProperties,
     ) -> impl FnOnce(TcpStream, AMQPUri) -> Result<(Wait<Connection>, IoLoop<TcpStream>), Error> + 'static
     {

diff --git a/src/io_loop.rs b/src/io_loop.rs
@@ -56,7 +56,7 @@ enum Status {
     Stop,
 }
 
-pub(crate) struct IoLoop<T> {
+pub struct IoLoop<T> {
     connection: Connection,
     socket: T,
     status: Status,
@@ -185,7 +185,7 @@ impl<T: Evented + Read + Write + Send + 'static> IoLoop<T> {
             && !connection_status.errored()
     }
 
-    pub(crate) fn run(mut self) -> Result<(), Error> {
+    pub fn run(mut self) -> Result<(), Error> {
         self.connection.clone().set_io_loop(
             ThreadBuilder::new()
                 .name("io_loop".to_owned())