refactor: format & specific compilation condition scope

examples/opfs/src/lib.rs

@@ -88,6 +88,7 @@ pub async fn async_reader() {
     assert_eq!(expected, read);
     web_sys::console::log_1(&format!("read data: {:?} from parquet", read).into());
 }
+
 #[wasm_bindgen]
 pub async fn remove_all_dir() {
     let fs_options = FsOptions::Local;

fusio/Cargo.toml

@@ -7,6 +7,9 @@ readme = "../README.md"
 repository.workspace = true
 version = "0.3.3"
 
+[package.metadata.docs.rs]
+all-features = true
+
 [features]
 aws = [
     "base64",
@@ -49,6 +52,7 @@ opfs = [
 tokio = ["async-stream", "dep:tokio"]
 tokio-http = ["dep:reqwest", "http"]
 tokio-uring = ["async-stream", "completion-based", "dep:tokio-uring", "no-send"]
+
 [[bench]]
 harness = false
 name = "tokio"

fusio/src/impls/remotes/aws/fs.rs

@@ -91,6 +91,7 @@ impl AmazonS3Builder {
         };
 
         AmazonS3 {
+            #[allow(clippy::arc_with_non_send_sync)]
             inner: Arc::new(AmazonS3Inner {
                 options: S3Options {
                     endpoint,

fusio/src/impls/remotes/aws/s3.rs

@@ -227,6 +227,7 @@ impl Write for S3File {
     async fn write_all<B: IoBuf>(&mut self, buf: B) -> (Result<(), Error>, B) {
         self.writer
             .get_or_insert_with(|| {
+                #[allow(clippy::arc_with_non_send_sync)]
                 S3Writer::new(Arc::new(MultipartUpload::new(
                     self.fs.clone(),
                     self.path.clone(),

fusio/src/lib.rs

@@ -95,7 +95,12 @@ pub unsafe trait MaybeSync: Sync {
 }
 
 #[cfg(feature = "no-send")]
-pub unsafe trait MaybeSync {}
+pub unsafe trait MaybeSync {
+    //! Same as [`MaybeSend`], but for [`std::marker::Sync`].
+    //!
+    //! # Safety
+    //! Do not implement it directly.
+}
 
 #[cfg(not(feature = "no-send"))]
 unsafe impl<T: Sync> MaybeSync for T {}
@@ -208,7 +213,6 @@ impl<W: Write> Write for &mut W {
 }
 
 #[cfg(test)]
-#[cfg(not(target_arch = "wasm32"))]
 mod tests {
     use super::{Read, Write};
     use crate::{buf::IoBufMut, Error, IoBuf};
@@ -322,6 +326,7 @@ mod tests {
     }
 
     #[allow(unused)]
+    #[cfg(not(target_arch = "wasm32"))]
     async fn test_local_fs<S>(fs: S) -> Result<(), Error>
     where
         S: crate::fs::Fs,
@@ -395,7 +400,7 @@ mod tests {
         write_and_read(File::from_std(write), File::from_std(read)).await;
     }
 
-    #[cfg(feature = "tokio")]
+    #[cfg(all(feature = "tokio", not(target_arch = "wasm32")))]
     #[tokio::test]
     async fn test_tokio_fs() {
         use crate::disk::TokioFs;
@@ -422,7 +427,7 @@ mod tests {
         }
     }
 
-    #[cfg(feature = "monoio")]
+    #[cfg(all(feature = "monoio", not(target_arch = "wasm32")))]
     #[monoio::test]
     async fn test_monoio() {
         use monoio::fs::File;