Use SendWrapper

Author: jccampagne

core/Cargo.lock

@@ -35,6 +35,7 @@ js-sys = "0.3.77"
 opendal-core = { path = "../../core", version = "0.55.0", default-features = false }
 serde = { workspace = true, features = ["derive"] }
 wasm-bindgen = "0.2.100"
+send_wrapper = "0.6"
 wasm-bindgen-futures = "0.4.50"
 web-sys = { version = "0.3.77", features = [
   "Blob",

core/services/opfs/Cargo.toml

@@ -15,6 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
+use send_wrapper::SendWrapper;
 use wasm_bindgen::JsCast;
 use wasm_bindgen_futures::JsFuture;
 use web_sys::FileSystemFileHandle;
@@ -24,20 +25,15 @@ use opendal_core::raw::*;
 use opendal_core::*;
 
 pub struct OpfsReader {
-    handle: FileSystemFileHandle,
+    handle: SendWrapper<FileSystemFileHandle>,
     range: BytesRange,
     done: bool,
 }
 
-/// Safety: wasm32 is single-threaded, `Send` and `Sync` are meaningless.
-unsafe impl Send for OpfsReader {}
-/// Safety: wasm32 is single-threaded, `Send` and `Sync` are meaningless.
-unsafe impl Sync for OpfsReader {}
-
 impl OpfsReader {
     pub fn new(handle: FileSystemFileHandle, range: BytesRange) -> Self {
         Self {
-            handle,
+            handle: SendWrapper::new(handle),
             range,
             done: false,
         }

core/services/opfs/src/reader.rs

@@ -15,6 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
+use send_wrapper::SendWrapper;
 use wasm_bindgen_futures::JsFuture;
 use web_sys::FileSystemWritableFileStream;
 
@@ -24,19 +25,14 @@ use opendal_core::*;
 use super::error::*;
 
 pub struct OpfsWriter {
-    stream: FileSystemWritableFileStream,
+    stream: SendWrapper<FileSystemWritableFileStream>,
     bytes_written: u64,
 }
 
-/// Safety: wasm32 is single-threaded, `Send` and `Sync` are meaningless.
-unsafe impl Send for OpfsWriter {}
-/// Safety: wasm32 is single-threaded, `Send` and `Sync` are meaningless.
-unsafe impl Sync for OpfsWriter {}
-
 impl OpfsWriter {
     pub fn new(stream: FileSystemWritableFileStream) -> Self {
         Self {
-            stream,
+            stream: SendWrapper::new(stream),
             bytes_written: 0,
         }
     }