Skip to content

Commit

Permalink
prep release
Browse files Browse the repository at this point in the history
  • Loading branch information
fafhrd91 committed May 5, 2022
1 parent a89c5c2 commit 3fe4f6f
Show file tree
Hide file tree
Showing 5 changed files with 8 additions and 7 deletions.
4 changes: 1 addition & 3 deletions CHANGES.md
Original file line number Diff line number Diff line change
@@ -1,11 +1,9 @@
# Changes

## [0.8.7] - 2022-05-04
## [0.8.6] - 2022-05-05

* v5: Account for property type byte in property length when encoding Subscribe packet

## [0.8.6] - 2022-xx-xx

* v5: Add Router::finish() helper method, it converts router to service factory

* v3/v3: Clearify session type for Router
Expand Down
2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ pin-project-lite = "0.2"
env_logger = "0.9"
ntex-tls = "0.1.3"
rustls = "0.20"
rustls-pemfile = "0.3"
rustls-pemfile = "1.0"
openssl = "0.10"

ntex = { version = "0.5", features = ["tokio", "rustls", "openssl"] }
2 changes: 1 addition & 1 deletion src/v3/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -500,7 +500,7 @@ where
Box::pin(async move {
let (hnd, mut delay) = req;

let result = match select((&*check)(&hnd), &mut delay).await {
let result = match select((*check)(&hnd), &mut delay).await {
Either::Left(res) => res,
Either::Right(_) => return Err(MqttError::HandshakeTimeout),
};
Expand Down
5 changes: 4 additions & 1 deletion src/v5/codec/decode.rs
Original file line number Diff line number Diff line change
Expand Up @@ -313,7 +313,10 @@ mod tests {
user_properties: Vec::new(),
});

assert_decode_packet(b"\x82\x15\x12\x34\x02\x0b\x01\x00\x04test\x01\x00\x06filter\x02", p);
assert_decode_packet(
b"\x82\x15\x12\x34\x02\x0b\x01\x00\x04test\x01\x00\x06filter\x02",
p,
);

let p = Packet::SubscribeAck(SubscribeAck {
packet_id: packet_id(0x1234),
Expand Down
2 changes: 1 addition & 1 deletion src/v5/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -591,7 +591,7 @@ where
Box::pin(async move {
let (mut hnd, mut delay) = req;

let result = match select((&*check)(&hnd), &mut delay).await {
let result = match select((*check)(&hnd), &mut delay).await {
Either::Left(res) => res,
Either::Right(_) => return Err(MqttError::HandshakeTimeout),
};
Expand Down

0 comments on commit 3fe4f6f

Please sign in to comment.