0.1.4: fix panic on empty batch

Author: hackermondev

Cargo.lock

@@ -9,7 +9,7 @@ cargo add batched
 Or add this to your `Cargo.toml`:
 ```toml
 [dependencies]
-batched = "0.1.3"
+batched = "0.1.4"
 ```
 
 ## #[batched]

README.md

@@ -1,7 +1,7 @@
 [package]
 name = "batched"
 description = "rust macro util for batching expensive operations"
-version = "0.1.3"
+version = "0.1.4"
 edition = "2024"
 license = "MIT"
 readme = "../README.md"
@@ -10,7 +10,7 @@ keywords = ["batch", "performance", "efficient"]
 
 
 [dependencies]
-batched_derive = { version = "0.1.3", path = "../batched_derive" }
+batched_derive = { version = "0.1.4", path = "../batched_derive" }
 
 [dev-dependencies]
 tokio = { version = "1.44.2", features = ["full"] }

batched/Cargo.toml

@@ -1,28 +1,30 @@
 use batched::batched;
 
-#[batched(window = 100, limit = 1000)]
-fn add(numbers: Vec<u32>) -> u32 {
-    numbers.iter().sum()
-}
-
 #[tokio::test]
 async fn simple() {
+    #[batched(window = 100, limit = 1000)]
+    fn add(numbers: Vec<u32>) -> u32 {
+        numbers.iter().sum()
+    }
+
     for _ in 0..99 {
-        tokio::task::spawn(async move { add_multiple(vec![1, 1, 1]).await });
+        tokio::task::spawn(async move { 
+            add_multiple(vec![1, 1, 1]).await
+        });
     }
 
     let total = add_multiple(vec![1, 1, 1]).await;
     let expected_total = 100 * 3;
     assert_eq!(total, expected_total);
 }
 
-#[batched(window = 100, limit = 1000, boxed)]
-fn error(_a: Vec<()>) -> Result<(), std::io::Error> {
-    return Err(std::io::Error::other("1234")).into();
-}
-
 #[tokio::test]
 async fn propagates_errors() {
+    #[batched(window = 100, limit = 1000, boxed)]
+    fn error(_a: Vec<()>) -> Result<(), std::io::Error> {
+        return Err(std::io::Error::other("1234")).into();
+    }
+
     let result = error(()).await;
     assert_eq!(result.is_err(), true);
 }

batched/tests/test.rs

@@ -1,7 +1,7 @@
 [package]
 name = "batched_derive"
 description = "rust macro util for batching expensive operations"
-version = "0.1.3"
+version = "0.1.4"
 edition = "2024"
 license = "MIT"
 readme = "../README.md"

batched_derive/Cargo.toml

@@ -83,7 +83,7 @@ pub fn build_code(call_function: Function, options: Attributes) -> TokenStream {
 
                     std::mem::swap(&mut calls, &mut buffer);
                     std::mem::swap(&mut return_channels, &mut channels);
-                    if calls.is_empty() {
+                    if calls.is_empty() && return_channels.is_empty() {
                         continue
                     }