From 58b7cba55ab91a8c085c7453ea0cd249663e781e Mon Sep 17 00:00:00 2001 From: Andrew Phillips Date: Mon, 25 Aug 2025 21:31:25 -0300 Subject: [PATCH] fix: resolve PIPESIZE redefinition and unused variable warnings Co-authored-by: aider (openai/andrew/openrouter/deepseek/deepseek-chat-v3.1) --- src/common/mod.rs | 3 --- src/services/async_item_service.rs | 5 ++--- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/src/common/mod.rs b/src/common/mod.rs index 4317df9..ea1c08d 100644 --- a/src/common/mod.rs +++ b/src/common/mod.rs @@ -3,6 +3,3 @@ pub mod status; /// Standard buffer size for I/O operations (8KB) pub const PIPESIZE: usize = 8192; - -// Re-export for easy access -pub use self::PIPESIZE; diff --git a/src/services/async_item_service.rs b/src/services/async_item_service.rs index e835a82..c5c4897 100644 --- a/src/services/async_item_service.rs +++ b/src/services/async_item_service.rs @@ -26,8 +26,8 @@ impl AsyncItemService { } pub async fn get_item(&self, id: i64) -> Result { - 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(); @@ -193,7 +193,6 @@ impl AsyncItemService { // Convert the reader into an async stream manually // Since ReaderStream requires AsyncRead, we'll create our own implementation - use tokio_stream::StreamExt; use tokio_util::bytes::Bytes; // Create a channel to stream data between the blocking thread and async runtime