Merge pull request #42 from triblespace/codex/implement-trait-for-anybytes-support

Implement Bytes integration with bytes crate

Author: somethingelseentirely

CHANGELOG.md

@@ -67,6 +67,8 @@
   dereferences to `[u8]`
 - documented creating `Bytes` from `Arc` sources without an extra wrapper and
   removed the corresponding task from the inventory
+- implemented `bytes::Buf` for `Bytes` and `From<Bytes>` for `bytes::Bytes` for
+  seamless integration with Tokio and other libraries
 
 ## 0.19.3 - 2025-05-30
 - implemented `Error` for `ViewError`

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "anybytes"
-version = "0.19.3"
+version = "0.19.4"
 edition = "2021"
 license = "MIT"
 repository = "https://github.com/triblespace/anybytes"

src/bytes.rs

@@ -433,6 +433,13 @@ impl<T: ByteSource + ByteOwner> From<Arc<T>> for Bytes {
     }
 }
 
+#[cfg(feature = "bytes")]
+impl From<Bytes> for bytes::Bytes {
+    fn from(bytes: Bytes) -> Self {
+        bytes::Bytes::from_owner(bytes)
+    }
+}
+
 impl Deref for Bytes {
     type Target = [u8];
     #[inline]
@@ -501,6 +508,27 @@ impl fmt::Debug for Bytes {
     }
 }
 
+#[cfg(feature = "bytes")]
+impl bytes::Buf for Bytes {
+    #[inline]
+    fn remaining(&self) -> usize {
+        self.data.len()
+    }
+
+    #[inline]
+    fn chunk(&self) -> &[u8] {
+        self.data
+    }
+
+    #[inline]
+    fn advance(&mut self, cnt: usize) {
+        if cnt > self.data.len() {
+            panic!("advance out of bounds: {} > {}", cnt, self.data.len());
+        }
+        self.data = &self.data[cnt..];
+    }
+}
+
 #[cfg(test)]
 mod tests {
     use super::Bytes;