From 9f7a98af3c4cbeb89b162c1faa4480553a3dc82e Mon Sep 17 00:00:00 2001 From: Carl Lerche Date: Sun, 4 Mar 2018 10:46:54 -0800 Subject: Switch TCP/UDP fns to poll_ -> Poll<...> style (#175) Tokio is moving away from using `WouldBlock`, instead favoring `Async::NotReady`. This patch updates the TCP and UDP types, deprecating any function that returns `WouldBlock` and adding a poll_ prefixed equivalent. --- examples/echo-udp.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'examples/echo-udp.rs') diff --git a/examples/echo-udp.rs b/examples/echo-udp.rs index f7e2bf09..18f2d393 100644 --- a/examples/echo-udp.rs +++ b/examples/echo-udp.rs @@ -10,9 +10,9 @@ //! //! Each line you type in to the `nc` terminal should be echo'd back to you! +#[macro_use] extern crate futures; extern crate tokio; -#[macro_use] extern crate tokio_io; use std::{env, io}; @@ -37,14 +37,14 @@ impl Future for Server { // If so then we try to send it back to the original source, waiting // until it's writable and we're able to do so. if let Some((size, peer)) = self.to_send { - let amt = try_nb!(self.socket.send_to(&self.buf[..size], &peer)); + let amt = try_ready!(self.socket.poll_send_to(&self.buf[..size], &peer)); println!("Echoed {}/{} bytes to {}", amt, size, peer); self.to_send = None; } // If we're here then `to_send` is `None`, so we take a look for the // next message we're going to echo back. - self.to_send = Some(try_nb!(self.socket.recv_from(&mut self.buf))); + self.to_send = Some(try_ready!(self.socket.poll_recv_from(&mut self.buf))); } } } -- cgit v1.2.3