Skip to content

Commit

Permalink
format fix
Browse files Browse the repository at this point in the history
  • Loading branch information
DenisBiryukov91 committed Mar 12, 2024
1 parent 5a08953 commit 0eb99c4
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 3 deletions.
2 changes: 1 addition & 1 deletion zenoh/src/sample.rs
Original file line number Diff line number Diff line change
Expand Up @@ -580,6 +580,6 @@ impl From<QoSType> for QoS {

impl From<QoS> for QoSType {
fn from(qos: QoS) -> Self {
qos.inner
qos.inner
}
}
14 changes: 12 additions & 2 deletions zenoh/tests/unicity.rs
Original file line number Diff line number Diff line change
Expand Up @@ -196,7 +196,12 @@ async fn test_unicity_qryrep(s01: &Session, s02: &Session, s03: &Session) {
.declare_queryable(key_expr)
.callback(move |sample| {
c_msgs1.fetch_add(1, Ordering::Relaxed);
task::block_on(async { ztimeout!(sample.reply(KeyExpr::try_from(key_expr).unwrap(), vec![0u8; size]).res_async()).unwrap() });
task::block_on(async {
ztimeout!(sample
.reply(KeyExpr::try_from(key_expr).unwrap(), vec![0u8; size])
.res_async())
.unwrap()
});
})
.res_async())
.unwrap();
Expand All @@ -208,7 +213,12 @@ async fn test_unicity_qryrep(s01: &Session, s02: &Session, s03: &Session) {
.declare_queryable(key_expr)
.callback(move |sample| {
c_msgs2.fetch_add(1, Ordering::Relaxed);
task::block_on(async { ztimeout!(sample.reply(KeyExpr::try_from(key_expr).unwrap(), vec![0u8; size]).res_async()).unwrap() });
task::block_on(async {
ztimeout!(sample
.reply(KeyExpr::try_from(key_expr).unwrap(), vec![0u8; size])
.res_async())
.unwrap()
});
})
.res_async())
.unwrap();
Expand Down

0 comments on commit 0eb99c4

Please sign in to comment.