diff options
| author | Carl Lerche <me@carllerche.com> | 2020-09-11 15:14:45 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-11 15:14:45 -0700 |
| commit | 2bc9a4815259c8ff4daa5e24f128ec826970d17f (patch) | |
| tree | c075e4d97a145ce104cfc8ee39d8d06acece5c13 /tokio/tests/async_send_sync.rs | |
| parent | c5a9ede157691ac5ca15283735bd666c6b016188 (diff) | |
sync: tweak `watch` API (#2814)
Decouples getting the latest `watch` value from receiving the change
notification. The `Receiver` async method becomes
`Receiver::changed()`. The latest value is obtained from
`Receiver::borrow()`.
The implementation is updated to use `Notify`. This requires adding
`Notify::notify_waiters`. This method is generally useful but is kept
private for now.
Diffstat (limited to 'tokio/tests/async_send_sync.rs')
| -rw-r--r-- | tokio/tests/async_send_sync.rs | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/tokio/tests/async_send_sync.rs b/tokio/tests/async_send_sync.rs index f1eed0e4..e7011e3b 100644 --- a/tokio/tests/async_send_sync.rs +++ b/tokio/tests/async_send_sync.rs @@ -205,7 +205,7 @@ async_assert_fn!(tokio::sync::Mutex<Rc<u8>>::lock(_): !Send & !Sync); async_assert_fn!(tokio::sync::Mutex<u8>::lock_owned(_): Send & Sync); async_assert_fn!(tokio::sync::Mutex<Cell<u8>>::lock_owned(_): Send & Sync); async_assert_fn!(tokio::sync::Mutex<Rc<u8>>::lock_owned(_): !Send & !Sync); -async_assert_fn!(tokio::sync::Notify::notified(_): Send & !Sync); +async_assert_fn!(tokio::sync::Notify::notified(_): Send & Sync); async_assert_fn!(tokio::sync::RwLock<u8>::read(_): Send & Sync); async_assert_fn!(tokio::sync::RwLock<u8>::write(_): Send & Sync); async_assert_fn!(tokio::sync::RwLock<Cell<u8>>::read(_): !Send & !Sync); @@ -229,9 +229,7 @@ async_assert_fn!(tokio::sync::mpsc::UnboundedReceiver<u8>::recv(_): Send & Sync) async_assert_fn!(tokio::sync::mpsc::UnboundedReceiver<Cell<u8>>::recv(_): Send & Sync); async_assert_fn!(tokio::sync::mpsc::UnboundedReceiver<Rc<u8>>::recv(_): !Send & !Sync); -async_assert_fn!(tokio::sync::watch::Receiver<u8>::recv(_): Send & Sync); -async_assert_fn!(tokio::sync::watch::Receiver<Cell<u8>>::recv(_): !Send & !Sync); -async_assert_fn!(tokio::sync::watch::Receiver<Rc<u8>>::recv(_): !Send & !Sync); +async_assert_fn!(tokio::sync::watch::Receiver<u8>::changed(_): Send & Sync); async_assert_fn!(tokio::sync::watch::Sender<u8>::closed(_): Send & Sync); async_assert_fn!(tokio::sync::watch::Sender<Cell<u8>>::closed(_): !Send & !Sync); async_assert_fn!(tokio::sync::watch::Sender<Rc<u8>>::closed(_): !Send & !Sync); |