Added LengthCodec, BincodeCodec and demo module

.devcontainer/devcontainer.json

@@ -0,0 +1,31 @@
+// For format details, see https://aka.ms/devcontainer.json. For config options, see the
+// README at: https://github.com/devcontainers/templates/tree/main/src/rust
+{
+	"name": "Rust",
+	// Or use a Dockerfile or Docker Compose file. More info: https://containers.dev/guide/dockerfile
+	"image": "mcr.microsoft.com/devcontainers/rust:1-1-bullseye",
+
+	// Use 'mounts' to make the cargo cache persistent in a Docker Volume.
+	"mounts": [
+		{
+			"source": "devcontainer-cargo-cache-${devcontainerId}",
+			"target": "/usr/local/cargo",
+			"type": "volume"
+		}
+	]
+
+	// Features to add to the dev container. More info: https://containers.dev/features.
+	// "features": {},
+
+	// Use 'forwardPorts' to make a list of ports inside the container available locally.
+	// "forwardPorts": [],
+
+	// Use 'postCreateCommand' to run commands after the container is created.
+	// "postCreateCommand": "rustc --version",
+
+	// Configure tool-specific properties.
+	// "customizations": {},
+
+	// Uncomment to connect as root instead. More info: https://aka.ms/dev-containers-non-root.
+	// "remoteUser": "root"
+}

.github/dependabot.yml

@@ -0,0 +1,12 @@
+# To get started with Dependabot version updates, you'll need to specify which
+# package ecosystems to update and where the package manifests are located.
+# Please see the documentation for more information:
+# https://docs.github.com/github/administering-a-repository/configuration-options-for-dependency-updates
+# https://containers.dev/guide/dependabot
+
+version: 2
+updates:
+ - package-ecosystem: "devcontainers"
+   directory: "/"
+   schedule:
+     interval: weekly

.github/workflows/tests.yml

@@ -84,10 +84,22 @@ jobs:
       - name: Clippy -- tracing
         run: cargo clippy --no-default-features --features="tracing" -- -D warnings
 
+      - name: Clippy -- bincode
+        run: cargo clippy --no-default-features --features="bincode" -- -D warnings
+
+      - name: Clippy -- demo
+        run: cargo clippy --no-default-features --features="demo" -- -D warnings
+
       # Test
 
       - name: Test
         run: cargo nextest run
 
       - name: Test -- buffer-early-shift
         run: cargo nextest run --features buffer-early-shift
+
+      - name: Test -- bincode
+        run: cargo nextest run --features "bincode,tokio,std"
+
+      - name: Test -- demo
+        run: cargo nextest run --features demo

Cargo.toml

@@ -5,38 +5,69 @@ edition = "2021"
 authors = ["Jad K. Haddad <jadkhaddad@gmail.com>"]
 license = "MIT OR Apache-2.0"
 readme = "README.md"
-description = "A simple and fast codec for encoding and decoding data in no_std environments"
+description = "A simple and zerocopy codec for encoding and decoding data in no_std environments."
 repository = "https://github.com/JadKHaddad/Cody-C"
 keywords = ["codec", "no_std", "embedded", "encode", "decode"]
 
 [features]
 default = ["char-fmt"]
-std = []
-tokio = ["dep:tokio"]
+std = ["bincode/std", "futures/std"]
+tokio = ["dep:tokio", "dep:tokio-util"]
 futures-io = ["futures/std"]
 embedded-io-async = ["dep:embedded-io-async"]
+bincode = ["dep:bincode"]
 log = ["dep:log"]
 tracing = ["dep:tracing"]
 defmt = ["dep:defmt"]
 pretty-hex-fmt = []
 char-fmt = []
 buffer-early-shift = []
+demo = [
+    "dep:zerocopy",
+    "dep:serde",
+    "dep:serde-json-core",
+    "dep:derive_more",
+    "dep:crc32fast",
+]
 
 [dependencies]
-tokio = { version = "1.37.0", optional = true, default-features = false, features = [
+tokio = { version = "1.41.0", default-features = false, features = [
     "io-util",
-] }
+], optional = true }
+tokio-util = { version = "0.7.12", default-features = false, features = [
+    "codec",
+], optional = true }
 embedded-io-async = { version = "0.6.1", optional = true }
 log = { version = "0.4.22", default-features = false, optional = true }
 tracing = { version = "0.1.40", default-features = false, optional = true }
 defmt = { version = "0.3.6", default-features = false, optional = true }
 futures = { version = "0.3.31", default-features = false }
 heapless = { version = "0.8.0", default-features = false }
+bincode = { version = "2.0.0-rc.3", default-features = false, optional = true }
+
+zerocopy = { version = "0.8.1", features = ["derive"], optional = true }
+serde = { version = "1.0.214", default-features = false, features = [
+    "derive",
+], optional = true }
+serde-json-core = { version = "0.6.0", optional = true }
+derive_more = { version = "1", default-features = false, features = [
+    "from",
+], optional = true }
+crc32fast = { version = "1.4.2", default-features = false, optional = true }
+
 
 [dev-dependencies]
 tokio = { version = "1", features = ["full"] }
 tracing = { version = "0.1.40", default-features = false }
 tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
+heapless = { version = "0.8.0", default-features = false, features = ["serde"] }
+serde = { version = "1.0.214", default-features = false, features = ["derive"] }
+bincode = { version = "2.0.0-rc.3", default-features = false, features = [
+    "derive",
+    "std",
+    "serde",
+] }
+
 
 [package.metadata.docs.rs]
 all-features = true

src/codec/any.rs

@@ -186,3 +186,93 @@ impl<const N: usize> Encoder<Vec<u8, N>> for AnyDelimiterCodecOwned<'_, N> {
         Encoder::encode(&mut self.inner, &item, dst)
     }
 }
+
+#[cfg(test)]
+mod test {
+    extern crate std;
+
+    use std::vec::Vec;
+
+    use futures::{pin_mut, SinkExt, StreamExt};
+    use tokio::io::AsyncWriteExt;
+
+    use crate::{
+        error, framed_read, sink_stream, test::init_tracing, tokio::Compat, FramedRead,
+        FramedReadError, FramedWrite,
+    };
+
+    use super::*;
+
+    #[tokio::test]
+    async fn framed_read() {
+        init_tracing();
+
+        let items: &[&[u8]] = &[
+            b"jh asjd##ppppppppppppppp##",
+            b"k hb##jsjuwjal kadj##jsadhjiu##w",
+            b"##jal kadjjsadhjiuwqens ##",
+            b"nd ",
+            b"yxxcjajsdi##askdn as",
+            b"jdasd##iouqw es",
+            b"sd##k",
+        ];
+
+        let decoder = AnyDelimiterCodec::new(b"##");
+
+        let expected: &[&[u8]] = &[];
+        framed_read!(items, expected, decoder, 1, BufferTooSmall);
+        framed_read!(items, expected, decoder, 1, 1, BufferTooSmall);
+        framed_read!(items, expected, decoder, 1, 2, BufferTooSmall);
+        framed_read!(items, expected, decoder, 1, 4, BufferTooSmall);
+
+        framed_read!(items, expected, decoder, 2, BufferTooSmall);
+        framed_read!(items, expected, decoder, 2, 1, BufferTooSmall);
+        framed_read!(items, expected, decoder, 2, 2, BufferTooSmall);
+        framed_read!(items, expected, decoder, 2, 4, BufferTooSmall);
+
+        framed_read!(items, expected, decoder, 4, BufferTooSmall);
+        framed_read!(items, expected, decoder, 4, 1, BufferTooSmall);
+        framed_read!(items, expected, decoder, 4, 2, BufferTooSmall);
+        framed_read!(items, expected, decoder, 4, 4, BufferTooSmall);
+
+        let expected: &[&[u8]] = &[b"jh asjd"];
+        framed_read!(items, expected, decoder, 16, BufferTooSmall);
+
+        let expected: &[&[u8]] = &[
+            b"jh asjd",
+            b"ppppppppppppppp",
+            b"k hb",
+            b"jsjuwjal kadj",
+            b"jsadhjiu",
+            b"w",
+            b"jal kadjjsadhjiuwqens ",
+            b"nd yxxcjajsdi",
+            b"askdn asjdasd",
+            b"iouqw essd",
+        ];
+        framed_read!(items, expected, decoder, 32, BytesRemainingOnStream);
+        framed_read!(items, expected, decoder, 32, 1, BytesRemainingOnStream);
+        framed_read!(items, expected, decoder, 32, 2, BytesRemainingOnStream);
+        framed_read!(items, expected, decoder, 32, 4, BytesRemainingOnStream);
+
+        framed_read!(items, expected, decoder);
+    }
+
+    #[tokio::test]
+    async fn sink_stream() {
+        init_tracing();
+
+        let items: Vec<heapless::Vec<u8, 32>> = std::vec![
+            heapless::Vec::from_slice(b"Hello").unwrap(),
+            heapless::Vec::from_slice(b"Hello, world!").unwrap(),
+            heapless::Vec::from_slice(b"Hei").unwrap(),
+            heapless::Vec::from_slice(b"sup").unwrap(),
+            heapless::Vec::from_slice(b"Hey").unwrap(),
+        ];
+
+        let decoder = AnyDelimiterCodecOwned::<32>::new(b"###");
+        let encoder = AnyDelimiterCodecOwned::<32>::new(b"###");
+
+        sink_stream!(encoder, decoder, items);
+    }
+}