Skip to content

Commit

Permalink
chore: format code [ci skip]
Browse files Browse the repository at this point in the history
  • Loading branch information
rubik committed Oct 11, 2019
1 parent d8039cc commit d1128f2
Showing 1 changed file with 7 additions and 17 deletions.
24 changes: 7 additions & 17 deletions src/message.rs
Original file line number Diff line number Diff line change
Expand Up @@ -183,16 +183,11 @@ mod tests {
let client = redis::Client::open("redis://127.0.0.1:6379/").unwrap();
let con = client.get_connection().unwrap();

let bm = BrokenMessage{};
let bm = BrokenMessage {};
let p = vec![1, 2, 3, 4];
let rc = RefCell::new(con);
let mg = MessageGuard::new(
bm,
p,
&rc,
"proc_test".into(),
"unack_test".into(),
);
let mg =
MessageGuard::new(bm, p, &rc, "proc_test".into(), "unack_test".into());

assert_eq!(Vec::from(mg.payload()), vec![1, 2, 3, 4]);
}
Expand All @@ -202,17 +197,12 @@ mod tests {
let client = redis::Client::open("redis://127.0.0.1:6379/").unwrap();
let con = client.get_connection().unwrap();

let bm = BrokenMessage{};
let bm = BrokenMessage {};
let p = vec![1, 2, 3, 4];
let rc = RefCell::new(con);
let mg = MessageGuard::new(
bm,
p,
&rc,
"proc_test".into(),
"unack_test".into(),
);
let mg =
MessageGuard::new(bm, p, &rc, "proc_test".into(), "unack_test".into());

assert_eq!(*mg.message(), BrokenMessage{});
assert_eq!(*mg.message(), BrokenMessage {});
}
}

0 comments on commit d1128f2

Please sign in to comment.