flexible connect-ack transition (#37)

ntex-rs · Oct 5, 2020 · b67d1dc · b67d1dc
1 parent 717a697
commit b67d1dc
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/src/lib.rs b/src/lib.rs
@@ -23,7 +23,7 @@ mod version;
 pub use self::error::MqttError;
 pub use self::server::MqttServer;
 pub use self::session::Session;
-pub use self::topic::Topic;
+pub use self::topic::{Topic, Level as TopicLevel};
 
 // http://www.iana.org/assignments/service-names-port-numbers/service-names-port-numbers.xhtml
 pub const TCP_PORT: u16 = 1883;

diff --git a/src/v5/connect.rs b/src/v5/connect.rs
@@ -69,6 +69,10 @@ impl<Io> Connect<Io> {
 
         ConnectAck { io: self.io, sink: self.sink, session: None, packet }
     }
+
+    pub fn fail_with<St>(self, ack: codec::ConnectAck) -> ConnectAck<Io, St> {
+        ConnectAck { io: self.io, sink: self.sink, session: None, packet: ack }
+    }
 }
 
 impl<T> fmt::Debug for Connect<T> {