smol-rs
/
nb-connect
mirror of https://github.com/smol-rs/nb-connect
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Update polling

This commit is contained in:
Stjepan Glavina 2020-10-04 11:15:18 +02:00
parent aa40b202c6
commit f010728414
3 changed files with 5 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Cargo.toml
View File

@ -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"

3
README.md
View File

@ -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 {

9
src/lib.rs
View File

@ -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<P: AsRef<Path>>(path: P) -> io::Result<UnixStream> {
///
/// // 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 {