diff --git a/monoio/src/driver/iocp/event.rs b/monoio/src/driver/iocp/event.rs index 0f962ff8..c4732f3d 100644 --- a/monoio/src/driver/iocp/event.rs +++ b/monoio/src/driver/iocp/event.rs @@ -118,3 +118,12 @@ impl Events { } } } + +impl<'a> IntoIterator for &'a Events { + type Item = &'a Event; + type IntoIter = std::slice::Iter<'a>; + + fn into_iter(self) -> Self::IntoIter { + self.events.iter() + } +} diff --git a/monoio/src/driver/iocp/mod.rs b/monoio/src/driver/iocp/mod.rs index 8f4b07ac..58b8c146 100644 --- a/monoio/src/driver/iocp/mod.rs +++ b/monoio/src/driver/iocp/mod.rs @@ -7,7 +7,7 @@ mod waker; pub use core::*; use std::{ collections::VecDeque, - os::windows::prelude::{AsRawHandle, RawSocket, RawHandle}, + os::windows::prelude::{AsRawHandle, RawHandle, RawSocket}, pin::Pin, sync::{ atomic::{AtomicBool, Ordering},