public buffer

core/src/layers/complete.rs

@@ -806,7 +806,7 @@ mod tests {
     #[tokio::test]
     async fn test_writer() {
         let op = new_test_operator(Capability::default());
-        let res = op.write("path", vec![]).await;
+        let res = op.write("path", Vec::<u8>::new()).await;
         assert!(res.is_err());
         assert_eq!(res.unwrap_err().kind(), ErrorKind::Unsupported);
 

core/src/types/operator/operator.rs

@@ -18,7 +18,6 @@
 use std::future::Future;
 use std::time::Duration;
 
-use bytes::Bytes;
 use futures::stream;
 use futures::Stream;
 use futures::StreamExt;
@@ -622,7 +621,7 @@ impl Operator {
     /// # Ok(())
     /// # }
     /// ```
-    pub async fn write(&self, path: &str, bs: impl Into<Bytes>) -> Result<()> {
+    pub async fn write(&self, path: &str, bs: impl Into<Buffer>) -> Result<()> {
         let bs = bs.into();
         self.write_with(path, bs).await
     }
@@ -1111,7 +1110,7 @@ impl Operator {
     pub fn write_with(
         &self,
         path: &str,
-        bs: impl Into<Bytes>,
+        bs: impl Into<Buffer>,
     ) -> FutureWrite<impl Future<Output = Result<()>>> {
         let path = normalize_path(path);
         let bs = bs.into();

core/src/types/operator/operator_futures.rs

@@ -23,7 +23,6 @@ use std::future::IntoFuture;
 use std::ops::RangeBounds;
 use std::time::Duration;
 
-use bytes::Bytes;
 use flagset::FlagSet;
 use futures::Future;
 
@@ -243,7 +242,7 @@ impl<F> FutureReader<F> {
 /// Future that generated by [`Operator::write_with`].
 ///
 /// Users can add more options by public functions provided by this struct.
-pub type FutureWrite<F> = OperatorFuture<(OpWrite, Bytes), F>;
+pub type FutureWrite<F> = OperatorFuture<(OpWrite, Buffer), F>;
 
 impl<F> FutureWrite<F> {
     /// Set the append mode of op.

core/src/types/writer.rs

@@ -422,14 +422,13 @@ mod tests {
 
         let content = gen_random_bytes();
         let mut writer = op.writer(path).await.unwrap();
-        writer.write(content.clone())
+        writer
+            .write(content.clone())
             .await
             .expect("write must succeed");
         writer.close().await.expect("close must succeed");
 
-        let buf = op.read(path)
-            .await
-            .expect("read to end mut succeed");
+        let buf = op.read(path).await.expect("read to end mut succeed");
 
         assert_eq!(buf.to_bytes(), content);
     }
@@ -441,14 +440,13 @@ mod tests {
 
         let content = gen_random_bytes();
         let mut writer = op.writer(path).await.unwrap();
-        writer.write_from(Bytes::from(content.clone()))
+        writer
+            .write_from(Bytes::from(content.clone()))
             .await
             .expect("write must succeed");
         writer.close().await.expect("close must succeed");
 
-        let buf = op.read(path)
-            .await
-            .expect("read to end mut succeed");
+        let buf = op.read(path).await.expect("read to end mut succeed");
 
         assert_eq!(buf.to_bytes(), content);
     }

core/tests/behavior/async_write.rs

@@ -80,7 +80,7 @@ pub async fn test_write_with_empty_content(op: Operator) -> Result<()> {
 
     let path = TEST_FIXTURE.new_file_path();
 
-    op.write(&path, vec![]).await?;
+    op.write(&path, Vec::<u8>::new()).await?;
 
     let meta = op.stat(&path).await.expect("stat must succeed");
     assert_eq!(meta.content_length(), 0);