From e8cef688a04c24ed6dd613d99cb3d7bec6fe930a Mon Sep 17 00:00:00 2001 From: Mackenzie Clark Date: Fri, 13 Sep 2019 12:18:13 -0700 Subject: [PATCH] change poll_next to poll_recv (#342) --- tower-buffer/src/worker.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tower-buffer/src/worker.rs b/tower-buffer/src/worker.rs index cb050b2..e41a6e5 100644 --- a/tower-buffer/src/worker.rs +++ b/tower-buffer/src/worker.rs @@ -115,7 +115,7 @@ where } // Get the next request - while let Some(mut msg) = ready!(Pin::new(&mut self.rx).poll_next(cx)) { + while let Some(mut msg) = ready!(Pin::new(&mut self.rx).poll_recv(cx)) { if msg.tx.poll_closed(cx).is_pending() { tracing::trace!("processing new request"); return Poll::Ready(Some((msg, true)));