Skip to content

Commit

Permalink
prep release
Browse files Browse the repository at this point in the history
  • Loading branch information
fafhrd91 committed Oct 28, 2021
1 parent 6c9bda4 commit d12dc64
Show file tree
Hide file tree
Showing 6 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion CHANGES.md
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
# Changes

## [0.7.4] - 2021-10-26
## [0.7.4] - 2021-10-29

* Expose some control plane type constructors

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.7.3"
version = "0.7.4"
authors = ["ntex contributors <[email protected]>"]
description = "Client and Server framework for MQTT v5 and v3.1.1 protocols"
documentation = "https://docs.rs/ntex-mqtt"
Expand Down
2 changes: 1 addition & 1 deletion src/v3/control.rs
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ impl<E> ControlMessage<E> {

/// Create a new `ControlMessage` from DISCONNECT packet.
#[doc(hidden)]
pub fn dis() -> Self {
pub fn remote_disconnect() -> Self {
ControlMessage::Disconnect(Disconnect)
}

Expand Down
2 changes: 1 addition & 1 deletion src/v3/dispatcher.rs
Original file line number Diff line number Diff line change
Expand Up @@ -208,7 +208,7 @@ where
)))
}
DispatchItem::Item(codec::Packet::Disconnect) => Either::Right(Either::Right(
ControlResponse::new(ControlMessage::dis(), &self.inner),
ControlResponse::new(ControlMessage::remote_disconnect(), &self.inner),
)),
DispatchItem::Item(_) => Either::Right(Either::Left(Ready::Ok(None))),
DispatchItem::EncoderError(err) => {
Expand Down
2 changes: 1 addition & 1 deletion src/v5/control.rs
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ impl<E> ControlMessage<E> {

/// Create a new `ControlMessage` from DISCONNECT packet.
#[doc(hidden)]
pub fn dis(pkt: codec::Disconnect) -> Self {
pub fn remote_disconnect(pkt: codec::Disconnect) -> Self {
ControlMessage::Disconnect(Disconnect(pkt))
}

Expand Down
2 changes: 1 addition & 1 deletion src/v5/dispatcher.rs
Original file line number Diff line number Diff line change
Expand Up @@ -255,7 +255,7 @@ where
ControlResponse::new(ControlMessage::ping(), &self.inner),
)),
DispatchItem::Item(codec::Packet::Disconnect(pkt)) => Either::Right(Either::Right(
ControlResponse::new(ControlMessage::dis(pkt), &self.inner),
ControlResponse::new(ControlMessage::remote_disconnect(pkt), &self.inner),
)),
DispatchItem::Item(codec::Packet::Subscribe(pkt)) => {
// register inflight packet id
Expand Down

0 comments on commit d12dc64

Please sign in to comment.