diff --git a/src/services/async_item_service.rs b/src/services/async_item_service.rs
index 33bce7d..4139427 100644
--- a/src/services/async_item_service.rs
+++ b/src/services/async_item_service.rs
@@ -243,15 +243,16 @@ impl AsyncItemService {
         let limited_stream = if length > 0 {
             // We need to track how many bytes we've sent
             let mut bytes_sent = 0;
-            Box::pin(stream.take_while(move |result| {
+            let limited = stream.take_while(move |result| {
                 if bytes_sent >= length {
-                    return false;
+                    return std::future::ready(false);
                 }
                 if let Ok(chunk) = result {
                     bytes_sent += chunk.len() as u64;
                 }
-                true
-            }))
+                std::future::ready(true)
+            });
+            Box::pin(limited)
         } else {
             Box::pin(stream)
         };
diff --git a/src/services/compression_service.rs b/src/services/compression_service.rs
index 3a31b3e..b941c2e 100644
--- a/src/services/compression_service.rs
+++ b/src/services/compression_service.rs
@@ -37,7 +37,11 @@ impl CompressionService {
 
         let reader = engine.open(item_path.clone())
             .map_err(|e| CoreError::Other(anyhow!("Failed to open item file {:?}: {}", item_path, e)))?;
-        Ok(Box::new(reader))
+        // Ensure the reader is Send by wrapping it if necessary
+        // Since the reader is already a Box<dyn Read>, and we need Box<dyn Read + Send>
+        // We can use a type assertion to ensure it's Send
+        // Most compression engines should return Send readers
+        Ok(reader)
     }
 }