docs: Add example for fusio_opendal (#92)

* docs: Add example for fusio_opendal

Signed-off-by: Xuanwo <[email protected]>

* chore: format

---------

Signed-off-by: Xuanwo <[email protected]>
Co-authored-by: Gwo Tzu-Hsing <[email protected]>

examples/Cargo.toml

@@ -12,5 +12,9 @@ tokio = ["dep:tokio", "fusio/tokio"]
 
 [dependencies]
 fusio = { path = "../fusio" }
+fusio-opendal = { path = "../fusio-opendal" }
 monoio = { version = "0.2", optional = true }
+opendal = { version = "0.50.1", default-features = false, features = [
+    "services-memory",
+] }
 tokio = { version = "1.0", features = ["full"], optional = true }

examples/src/lib.rs

@@ -1,6 +1,7 @@
 mod fs;
 mod multi_runtime;
 mod object;
+mod opendal;
 mod s3;
 
 use fusio::{Error, IoBuf, IoBufMut, Read, Write};

examples/src/opendal.rs

@@ -0,0 +1,22 @@
+use std::sync::Arc;
+
+use fusio::{dynamic::DynFile, DynFs};
+use fusio_opendal::OpendalFs;
+use opendal::{services::Memory, Operator};
+
+#[allow(unused)]
+async fn use_opendalfs() {
+    let op = Operator::new(Memory::default()).unwrap().finish();
+    let fs: Arc<dyn DynFs> = Arc::new(OpendalFs::from(op));
+
+    let mut file: Box<dyn DynFile> = Box::new(fs.open(&"foo.txt".into()).await.unwrap());
+
+    let write_buf = "hello, world".as_bytes();
+    let mut read_buf = [0; 12];
+
+    let (result, _, read_buf) =
+        crate::write_without_runtime_awareness(&mut file, write_buf, &mut read_buf[..]).await;
+    result.unwrap();
+
+    assert_eq!(&read_buf, b"hello, world");
+}