aboutsummaryrefslogtreecommitdiff
path: root/embassy-sync/src
diff options
context:
space:
mode:
authorPeter Krull <[email protected]>2024-02-29 16:58:21 +0100
committerPeter Krull <[email protected]>2024-02-29 16:58:21 +0100
commitc08e75057a4282a0dfee13a6e181a2077944c1b0 (patch)
treefba49f1a094fe5db0d860de9e18a2b1d5af3bfb9 /embassy-sync/src
parent3208e0fec4717ff1580d1cc0cf93e18cbba2db91 (diff)
Update tests to reflect changes in previous commit
Diffstat (limited to 'embassy-sync/src')
-rw-r--r--embassy-sync/src/watch.rs18
1 files changed, 9 insertions, 9 deletions
diff --git a/embassy-sync/src/watch.rs b/embassy-sync/src/watch.rs
index 2bba93915..1301eb817 100644
--- a/embassy-sync/src/watch.rs
+++ b/embassy-sync/src/watch.rs
@@ -551,16 +551,16 @@ mod tests {
551 let rcv2 = WATCH.receiver(); 551 let rcv2 = WATCH.receiver();
552 552
553 // Ensure the first two are successful and the third is not 553 // Ensure the first two are successful and the third is not
554 assert!(rcv0.is_ok()); 554 assert!(rcv0.is_some());
555 assert!(rcv1.is_ok()); 555 assert!(rcv1.is_some());
556 assert!(rcv2.is_err()); 556 assert!(rcv2.is_none());
557 557
558 // Drop the first receiver 558 // Drop the first receiver
559 drop(rcv0); 559 drop(rcv0);
560 560
561 // Create another receiver and ensure it is successful 561 // Create another receiver and ensure it is successful
562 let rcv3 = WATCH.receiver(); 562 let rcv3 = WATCH.receiver();
563 assert!(rcv3.is_ok()); 563 assert!(rcv3.is_some());
564 }; 564 };
565 block_on(f); 565 block_on(f);
566 } 566 }
@@ -693,9 +693,9 @@ mod tests {
693 let rcv2 = WATCH.receiver(); 693 let rcv2 = WATCH.receiver();
694 694
695 // Ensure the first two are successful and the third is not 695 // Ensure the first two are successful and the third is not
696 assert!(rcv0.is_ok()); 696 assert!(rcv0.is_some());
697 assert!(rcv1.is_ok()); 697 assert!(rcv1.is_some());
698 assert!(rcv2.is_err()); 698 assert!(rcv2.is_none());
699 699
700 // Convert to dynamic 700 // Convert to dynamic
701 let dyn_rcv0 = rcv0.unwrap().as_dyn(); 701 let dyn_rcv0 = rcv0.unwrap().as_dyn();
@@ -706,8 +706,8 @@ mod tests {
706 // Create another receiver and ensure it is successful 706 // Create another receiver and ensure it is successful
707 let rcv3 = WATCH.receiver(); 707 let rcv3 = WATCH.receiver();
708 let rcv4 = WATCH.receiver(); 708 let rcv4 = WATCH.receiver();
709 assert!(rcv3.is_ok()); 709 assert!(rcv3.is_some());
710 assert!(rcv4.is_err()); 710 assert!(rcv4.is_none());
711 }; 711 };
712 block_on(f); 712 block_on(f);
713 } 713 }