diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index 2bb9a234..8296d085 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -18,7 +18,7 @@ jobs: - { name: Windows (MinGW), os: windows-latest, triple: x86_64-pc-windows-gnu } - { name: Windows (32-bit), os: windows-latest, triple: i686-pc-windows-msvc } version: - - 1.46.0 # MSRV + - 1.51.0 # MSRV - stable - nightly diff --git a/actix-server/src/waker.rs b/actix-server/src/waker.rs index 7baed05b..af060bd9 100644 --- a/actix-server/src/waker.rs +++ b/actix-server/src/waker.rs @@ -99,18 +99,20 @@ mod test { #[test] fn test_waker_channel() { - let poll = mio::Poll::new().unwrap(); + let mut poll = mio::Poll::new().unwrap(); let waker = from_registry(poll.registry()).unwrap(); - let cx = &mut Context::from_waker(&waker); let (tx, mut rx) = waker_channel(); - assert!(rx.poll_recv(cx).is_pending()); tx.wake(super::WakerInterest::Stop); + let mut events = mio::Events::with_capacity(1); + poll.poll(&mut events, None).unwrap(); + assert_eq!(events.iter().next().unwrap().token(), WAKER_TOKEN); + match rx.poll_recv(cx) { Poll::Ready(Some(WakerInterest::Stop)) => {} _ => panic!("Failed to wake up WakerRx"),