Skip to content

Commit

Permalink
Fix typo (#152)
Browse files Browse the repository at this point in the history
  • Loading branch information
fafhrd91 committed Oct 23, 2023
1 parent 2bab9df commit 39078cb
Show file tree
Hide file tree
Showing 7 changed files with 40 additions and 1 deletion.
4 changes: 4 additions & 0 deletions CHANGES.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,9 @@
# Changes

## [0.12.5] - 2023-10-23

* Fix typo

## [0.12.4] - 2023-10-03

* Fix nested error handling for control service
Expand Down
2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "ntex-mqtt"
version = "0.12.4"
version = "0.12.5"
authors = ["ntex contributors <team@ntex.rs>"]
description = "Client and Server framework for MQTT v5 and v3.1.1 protocols"
documentation = "https://docs.rs/ntex-mqtt"
Expand Down
7 changes: 7 additions & 0 deletions src/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,13 @@ impl<V3, V5, Err, InitErr> MqttServer<V3, V5, Err, InitErr> {
/// Mqtt::Handshake(HandshakeError::Timeout) error.
///
/// By default, connect timeuot is 10 seconds.
pub fn connect_timeout(mut self, timeout: Seconds) -> Self {
self.connect_timeout = timeout.into();
self
}

#[deprecated(since = "0.12.5")]
#[doc(hidden)]
pub fn conenct_timeout(mut self, timeout: Seconds) -> Self {
self.connect_timeout = timeout.into();
self
Expand Down
7 changes: 7 additions & 0 deletions src/v3/selector.rs
Original file line number Diff line number Diff line change
Expand Up @@ -54,6 +54,13 @@ where
/// Mqtt::Handshake(HandshakeError::Timeout) error.
///
/// By default, connect timeuot is 10 seconds.
pub fn connect_timeout(mut self, timeout: Seconds) -> Self {
self.connect_timeout = timeout.into();
self
}

#[deprecated(since = "0.12.5")]
#[doc(hidden)]
pub fn conenct_timeout(mut self, timeout: Seconds) -> Self {
self.connect_timeout = timeout.into();
self
Expand Down
7 changes: 7 additions & 0 deletions src/v3/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -100,6 +100,13 @@ where
/// Mqtt::Handshake(HandshakeError::Timeout) error.
///
/// By default, connect timeout is disabled.
pub fn connect_timeout(mut self, timeout: Seconds) -> Self {
self.connect_timeout = timeout;
self
}

#[deprecated(since = "0.12.5")]
#[doc(hidden)]
pub fn conenct_timeout(mut self, timeout: Seconds) -> Self {
self.connect_timeout = timeout;
self
Expand Down
7 changes: 7 additions & 0 deletions src/v5/selector.rs
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,13 @@ where
/// Mqtt::Handshake(HandshakeError::Timeout) error.
///
/// By default, connect timeout is disabled.
pub fn connect_timeout(mut self, timeout: Seconds) -> Self {
self.connect_timeout = timeout.into();
self
}

#[deprecated(since = "0.12.5")]
#[doc(hidden)]
pub fn conenct_timeout(mut self, timeout: Seconds) -> Self {
self.connect_timeout = timeout.into();
self
Expand Down
7 changes: 7 additions & 0 deletions src/v5/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,13 @@ where
/// Mqtt::Handshake(HandshakeError::Timeout) error.
///
/// By default, connect timeout is disabled.
pub fn connect_timeout(mut self, timeout: Seconds) -> Self {
self.connect_timeout = timeout;
self
}

#[deprecated(since = "0.12.5")]
#[doc(hidden)]
pub fn conenct_timeout(mut self, timeout: Seconds) -> Self {
self.connect_timeout = timeout;
self
Expand Down

0 comments on commit 39078cb

Please sign in to comment.