From f010728414a0c4e39c6a8b74eb5d8ea3b6ac5ada Mon Sep 17 00:00:00 2001 From: Stjepan Glavina Date: Sun, 4 Oct 2020 11:15:18 +0200 Subject: [PATCH] Update polling --- Cargo.toml | 2 +- README.md | 3 +-- src/lib.rs | 9 +++------ 3 files changed, 5 insertions(+), 9 deletions(-) diff --git a/Cargo.toml b/Cargo.toml index 18b344c..bb07260 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -22,4 +22,4 @@ libc = "0.2.77" winapi = { version = "0.3.9", features = ["handleapi", "ws2tcpip"] } [dev-dependencies] -polling = "1.0.2" +polling = "2.0.0" diff --git a/README.md b/README.md index 8b79201..5b35489 100644 --- a/README.md +++ b/README.md @@ -28,8 +28,7 @@ let stream = nb_connect::tcp(([127, 0, 0, 1], 80))?; // Create a poller that waits for the stream to become writable. let poller = Poller::new()?; -poller.insert(&stream); -poller.interest(&stream, Event::writable(0))?; +poller.add(&stream, Event::writable(0))?; // Wait for at most 1 second. if poller.wait(&mut Vec::new(), Some(Duration::from_secs(1)))? == 0 { diff --git a/src/lib.rs b/src/lib.rs index d371b4c..894a5ad 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -17,8 +17,7 @@ //! //! // Create a poller that waits for the stream to become writable. //! let poller = Poller::new()?; -//! poller.insert(&stream); -//! poller.interest(&stream, Event::writable(0))?; +//! poller.add(&stream, Event::writable(0))?; //! //! // Wait for at most 1 second. //! if poller.wait(&mut Vec::new(), Some(Duration::from_secs(1)))? == 0 { @@ -173,8 +172,7 @@ fn connect(addr: Addr, family: libc::c_int, protocol: libc::c_int) -> io::Result /// /// // Create a poller that waits for the stream to become writable. /// let poller = Poller::new()?; -/// poller.insert(&stream); -/// poller.interest(&stream, Event::writable(0))?; +/// poller.add(&stream, Event::writable(0))?; /// /// // Wait for at most 1 second. /// if poller.wait(&mut Vec::new(), Some(Duration::from_secs(1)))? == 0 { @@ -252,8 +250,7 @@ pub fn unix>(path: P) -> io::Result { /// /// // Create a poller that waits for the stream to become writable. /// let poller = Poller::new()?; -/// poller.insert(&stream); -/// poller.interest(&stream, Event::writable(0))?; +/// poller.add(&stream, Event::writable(0))?; /// /// // Wait for at most 1 second. /// if poller.wait(&mut Vec::new(), Some(Duration::from_secs(1)))? == 0 {