diff options
| author | Zephyr Shannon <earthlingzephyr@gmail.com> | 2020-10-19 01:12:40 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-10-19 10:12:40 +0200 |
| commit | fb28caa90c8ab4453b259424c88dc7ec8ff06bbb (patch) | |
| tree | ad2e0ddd41b188b7b7e794ccb7a3baba8377b250 /tokio/src/sync/tests/loom_broadcast.rs | |
| parent | e88e64bcc07f4a632014815a5fec3e67d97a8f31 (diff) | |
sync: implement Clone for broadcast::Receiver (#2933)
Diffstat (limited to 'tokio/src/sync/tests/loom_broadcast.rs')
| -rw-r--r-- | tokio/src/sync/tests/loom_broadcast.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/tokio/src/sync/tests/loom_broadcast.rs b/tokio/src/sync/tests/loom_broadcast.rs index 4b1f034f..e15dc25f 100644 --- a/tokio/src/sync/tests/loom_broadcast.rs +++ b/tokio/src/sync/tests/loom_broadcast.rs @@ -92,11 +92,12 @@ fn broadcast_two() { }); } +// Exercise the Receiver Clone impl as well #[test] fn broadcast_wrap() { loom::model(|| { let (tx, mut rx1) = broadcast::channel(2); - let mut rx2 = tx.subscribe(); + let mut rx2 = rx1.clone(); let th1 = thread::spawn(move || { block_on(async { |