fix: MonoioFS execute blocking task without thread pool attached

fusio-opendal/src/fs.rs

@@ -72,6 +72,8 @@ impl Fs for OpendalFs {
     }
 
     async fn link(&self, from: &Path, to: &Path) -> Result<(), Error> {
-        todo!()
+        Err(Error::Unsupported {
+            message: "opendal does not support link file".to_string(),
+        })
     }
 }

fusio/src/error.rs

@@ -22,9 +22,6 @@ pub enum Error {
     Wasm {
         message: String,
     },
-    #[cfg(feature = "monoio")]
-    #[error("monoio JoinHandle was canceled")]
-    MonoIOJoinCancel,
     #[error(transparent)]
     Other(#[from] BoxedError),
 }
@@ -37,8 +34,3 @@ pub(crate) fn wasm_err(js_val: js_sys::wasm_bindgen::JsValue) -> Error {
         message: format!("{js_val:?}"),
     }
 }
-
-#[cfg(feature = "monoio")]
-pub(crate) fn monoio_join_err(_: monoio::blocking::JoinError) -> Error {
-    Error::MonoIOJoinCancel
-}

fusio/src/impls/disk/monoio/fs.rs

@@ -2,11 +2,9 @@ use std::{fs, fs::create_dir_all};
 
 use async_stream::stream;
 use futures_core::Stream;
-use monoio::blocking::spawn_blocking;
 
 use super::MonoioFile;
 use crate::{
-    error::monoio_join_err,
     fs::{FileMeta, FileSystemTag, Fs, OpenOptions},
     path::{path_to_local, Path},
     Error,
@@ -67,9 +65,7 @@ impl Fs for MonoIoFs {
         let from = path_to_local(from)?;
         let to = path_to_local(to)?;
 
-        spawn_blocking(move || fs::copy(&from, &to))
-            .await
-            .map_err(monoio_join_err)??;
+        let _ = monoio::spawn(async move { fs::copy(&from, &to) }).await?;
 
         Ok(())
     }
@@ -78,9 +74,7 @@ impl Fs for MonoIoFs {
         let from = path_to_local(from)?;
         let to = path_to_local(to)?;
 
-        spawn_blocking(move || fs::hard_link(&from, &to))
-            .await
-            .map_err(monoio_join_err)??;
+        let _ = monoio::spawn(async move { fs::hard_link(&from, &to) }).await?;
 
         Ok(())
     }