|
|
|
@ -102,9 +102,9 @@ mod test {
@@ -102,9 +102,9 @@ mod test {
|
|
|
|
|
publ.send(TestMsg(20)).unwrap(); |
|
|
|
|
publ.send(TestMsg(30)).unwrap(); |
|
|
|
|
|
|
|
|
|
assert_eq!(sub.try_recv(), Ok(TestMsg(10))); |
|
|
|
|
assert_eq!(sub.try_recv(), Ok(TestMsg(20))); |
|
|
|
|
assert_eq!(sub.try_recv(), Ok(TestMsg(30))); |
|
|
|
|
assert_eq!(sub.recv_blocking(), Ok(TestMsg(10))); |
|
|
|
|
assert_eq!(sub.recv_blocking(), Ok(TestMsg(20))); |
|
|
|
|
assert_eq!(sub.recv_blocking(), Ok(TestMsg(30))); |
|
|
|
|
assert_eq!(sub.try_recv(), Err(RecvError::Empty)); |
|
|
|
|
}) |
|
|
|
|
.await |
|
|
|
|