diff --git a/src/services/async_item_service.rs b/src/services/async_item_service.rs
index c5c4897..5ce681b 100644
--- a/src/services/async_item_service.rs
+++ b/src/services/async_item_service.rs
@@ -170,17 +170,17 @@ impl AsyncItemService {
         
         // Get a streaming reader for the content
         let reader = {
-            let _db = self.db.clone();
-            let _item_service = self.item_service.clone();
+            let db = self.db.clone();
+            let item_service = self.item_service.clone();
             tokio::task::spawn_blocking(move || {
-                let conn = _db.blocking_lock();
-                let item_with_meta = _item_service.get_item(&conn, item_id)?;
+                let conn = db.blocking_lock();
+                let item_with_meta = item_service.get_item(&conn, item_id)?;
                 let item_id_val = item_with_meta.item.id.ok_or_else(|| CoreError::InvalidInput("Item missing ID".to_string()))?;
                 
-                let mut item_path = _item_service.get_data_path().clone();
+                let mut item_path = item_service.get_data_path().clone();
                 item_path.push(item_id_val.to_string());
                 
-                let reader = _item_service.get_compression_service().stream_item_content(
+                let reader = item_service.get_compression_service().stream_item_content(
                     item_path, 
                     &item_with_meta.item.compression
                 )?;