wip

Author: o0Ignition0o

src/proactor.rs

@@ -1,6 +1,6 @@
+use std::task::{Context, Poll};
 use std::time::Duration;
-use std::task::{Poll, Context};
-use std::{pin::Pin, future::Future, io};
+use std::{future::Future, io, pin::Pin};
 
 use lever::prelude::*;
 use once_cell::sync::Lazy;
@@ -9,6 +9,9 @@ use super::syscore::*;
 use super::waker::*;
 use crate::spawn_blocking;
 
+#[cfg(target_os = "windows")]
+use crate::syscore::iocp::SysProactor;
+
 pub use super::handle::*;
 
 ///
@@ -18,9 +21,8 @@ pub struct Proactor(SysProactor);
 impl Proactor {
     /// Returns a reference to the proactor.
     pub fn get() -> &'static Proactor {
-        static PROACTOR: Lazy<Proactor> = Lazy::new(|| Proactor(
-            SysProactor::new().expect("cannot initialize poll backend")
-        ));
+        static PROACTOR: Lazy<Proactor> =
+            Lazy::new(|| Proactor(SysProactor::new().expect("cannot initialize poll backend")));
 
         &PROACTOR
     }
@@ -52,10 +54,8 @@ pub fn drive<T>(future: impl Future<Output = T>) -> T {
     let cx = &mut Context::from_waker(&waker);
     futures_util::pin_mut!(future);
 
-    let driver = spawn_blocking(move || {
-        loop {
-            let _ = p.wait(1, None);
-        }
+    let driver = spawn_blocking(move || loop {
+        let _ = p.wait(1, None);
     });
 
     futures_util::pin_mut!(driver);
@@ -70,4 +70,4 @@ pub fn drive<T>(future: impl Future<Output = T>) -> T {
         let duration = Duration::from_millis(1);
         driver.as_mut().poll(cx);
     }
-}
+}

src/syscore/windows/iocp.rs

@@ -0,0 +1,23 @@
+pub struct SysProactor {}
+
+impl SysProactor {
+    /// Returns a reference to the proactor.
+    pub fn new() -> Result<Self, ()> {
+        Ok(Self {})
+    }
+
+    /// Wakes the thread waiting on proactor.
+    pub fn wake(&self) {
+        todo!();
+    }
+
+    /// Wait for completion of IO object
+    pub fn wait(&self, max_event_size: usize, duration: Option<Duration>) -> io::Result<usize> {
+        todo!();
+    }
+
+    /// Get underlying proactor instance.
+    pub(crate) fn inner(&self) -> &SysProactor {
+        todo!();
+    }
+}

src/syscore/windows/mod.rs

@@ -1,2 +1,2 @@
-mod nethandle;
-mod iocp;
+pub mod iocp;
+pub mod nethandle;

src/syscore/windows/nethandle.rs

@@ -0,0 +1,3 @@
+struct SysProactor {}
+
+impl SysProactor {}