feat: use latest runtime

Author: Berrysoft

src/lib.rs

@@ -33,16 +33,16 @@ impl<A: sys::Adapter> RuntimeCompat<A> {
                 return result;
             }
 
-            let remaining_tasks = self.runtime.enter(|| self.runtime.run());
+            let mut remaining_tasks = self.runtime.enter(|| self.runtime.run());
+
+            remaining_tasks |= self.runtime.flush();
 
             let timeout = if remaining_tasks {
                 Some(Duration::ZERO)
             } else {
                 self.runtime.current_timeout()
             };
 
-            self.runtime.submit();
-
             match self.runtime.wait(timeout).await {
                 Ok(_) => {}
                 Err(e)

src/sys/mod.rs

@@ -17,13 +17,6 @@ cfg_if::cfg_if! {
 pub trait Adapter: Sized + Deref<Target = Runtime> {
     fn new(runtime: Runtime) -> io::Result<Self>;
 
-    fn submit(&self) {
-        // io-uring needs to be submitted before waiting.
-        if self.driver_type().is_iouring() {
-            self.poll_with(Some(Duration::ZERO));
-        }
-    }
-
     async fn wait(&self, timeout: Option<Duration>) -> io::Result<()>;
 
     fn clear(&self) -> io::Result<()>;

tests/fs.rs

@@ -8,7 +8,7 @@ async fn test_impl<A: Adapter>() {
     let runtime = RuntimeCompat::<A>::new(runtime).unwrap();
     let buffer = runtime
         .execute(async {
-            let mut file = File::open("Cargo.toml").await.unwrap();
+            let file = File::open("Cargo.toml").await.unwrap();
             let (_, buffer) = file.read_to_string_at(String::new(), 0).await.unwrap();
             buffer
         })