diff options
Diffstat (limited to 'tokio/tests/rt_common.rs')
| -rw-r--r-- | tokio/tests/rt_common.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/tokio/tests/rt_common.rs b/tokio/tests/rt_common.rs index 73982ced..2637793a 100644 --- a/tokio/tests/rt_common.rs +++ b/tokio/tests/rt_common.rs @@ -41,7 +41,7 @@ rt_test! { use tokio::time; use tokio_test::{assert_err, assert_ok}; - use futures_util::future::poll_fn; + use futures::future::poll_fn; use std::future::Future; use std::pin::Pin; use std::sync::{mpsc, Arc}; @@ -133,12 +133,12 @@ rt_test! { let mut txs = (0..ITER) .map(|i| { let (tx, rx) = oneshot::channel(); - let mut done_tx = done_tx.clone(); + let done_tx = done_tx.clone(); tokio::spawn(async move { let msg = assert_ok!(rx.await); assert_eq!(i, msg); - assert_ok!(done_tx.try_send(msg)); + assert_ok!(done_tx.send(msg)); }); tx |