diff --git a/Cargo.toml b/Cargo.toml index 9bbbcad..9804c3e 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -45,7 +45,7 @@ optional = true nix = "0.17.0" [target.'cfg(windows)'.dependencies] -wepoll-binding = "2.0.0" +wepoll-binding = "2.0.2" [dev-dependencies] futures = { version = "0.3.5", default-features = false, features = ["std"] } diff --git a/src/reactor.rs b/src/reactor.rs index a6884cc..9c6089f 100644 --- a/src/reactor.rs +++ b/src/reactor.rs @@ -714,11 +714,9 @@ mod sys { Events(wepoll_binding::Events::with_capacity(1000)) } pub fn iter(&self) -> impl Iterator + '_ { - // wepoll doesn't report events so we have to assume both readability and writabilit - // events have been emitted. self.0.iter().map(|ev| Event { - readable: true, - writable: true, + readable: ev.flags().intersects(read_flags()), + writable: ev.flags().intersects(write_flags()), key: ev.data() as usize, }) }