1 files changed, 3 insertions, 1 deletions
diff --git a/tokio-test/src/io.rs b/tokio-test/src/io.rs
index 4f0b5897..b91ddc34 100644
--- a/tokio-test/src/io.rs
+++ b/tokio-test/src/io.rs
@@ -200,7 +200,9 @@ impl Inner {
     }
 
     fn poll_action(&mut self, cx: &mut task::Context<'_>) -> Poll<Option<Action>> {
-        self.rx.poll_recv(cx)
+        use futures_core::stream::Stream;
+
+        Pin::new(&mut self.rx).poll_next(cx)
     }
 
     fn read(&mut self, dst: &mut ReadBuf<'_>) -> io::Result<()> {