From 61943b16acdfed3fa45cb57a5331e6f8fd6e14da Mon Sep 17 00:00:00 2001 From: x1a0b0 Date: Mon, 13 Oct 2025 11:34:44 +0800 Subject: [PATCH] Apply clippy lint Signed-off-by: x1a0b0 --- packages/client-rust/src/bin/client.rs | 9 +++------ packages/client-rust/src/bin/monitor.rs | 2 +- packages/client-rust/src/services/audio/play.rs | 2 +- packages/client-rust/src/utils/event.rs | 5 +---- packages/client-rust/src/utils/mod.rs | 2 +- packages/client-rust/src/utils/task.rs | 2 +- 6 files changed, 8 insertions(+), 14 deletions(-) diff --git a/packages/client-rust/src/bin/client.rs b/packages/client-rust/src/bin/client.rs index 38b4b90..532ef13 100644 --- a/packages/client-rust/src/bin/client.rs +++ b/packages/client-rust/src/bin/client.rs @@ -147,12 +147,9 @@ async fn on_event(event: Event) -> Result<(), AppError> { async fn on_stream(stream: Stream) -> Result<(), AppError> { let Stream { tag, bytes, .. } = stream; - match tag.as_str() { - "play" => { - // 播放接收到的音频流 - let _ = AudioPlayer::instance().play(bytes).await; - } - _ => {} + if tag.as_str() == "play" { + // 播放接收到的音频流 + let _ = AudioPlayer::instance().play(bytes).await; } Ok(()) } diff --git a/packages/client-rust/src/bin/monitor.rs b/packages/client-rust/src/bin/monitor.rs index efcba17..69c6dac 100644 --- a/packages/client-rust/src/bin/monitor.rs +++ b/packages/client-rust/src/bin/monitor.rs @@ -29,7 +29,7 @@ async fn on_keyword(_keyword: String) { .split("\n") .filter(|line| !line.trim().is_empty()) .collect::>(); - if replies.len() > 0 { + if !replies.is_empty() { wakeup_sounds.clear(); wakeup_sounds.extend(replies.iter().map(|s| s.to_string())); } diff --git a/packages/client-rust/src/services/audio/play.rs b/packages/client-rust/src/services/audio/play.rs index d12321d..90d8919 100644 --- a/packages/client-rust/src/services/audio/play.rs +++ b/packages/client-rust/src/services/audio/play.rs @@ -39,7 +39,7 @@ impl AudioPlayer { } if let Some(task) = self.player_task.lock().await.take() { - let _ = task.abort(); + task.abort(); } if let Some(mut write_thread) = self.write_thread.lock().await.take() { diff --git a/packages/client-rust/src/utils/event.rs b/packages/client-rust/src/utils/event.rs index dde5000..d02e634 100644 --- a/packages/client-rust/src/utils/event.rs +++ b/packages/client-rust/src/utils/event.rs @@ -73,9 +73,6 @@ impl EventBus { async fn get_callbacks(&self, event: &str) -> Option> { let subscribers = self.subscribers.lock().await; - match subscribers.get(event) { - Some(callbacks) => Some(callbacks.clone()), - None => None, - } + subscribers.get(event).cloned() } } diff --git a/packages/client-rust/src/utils/mod.rs b/packages/client-rust/src/utils/mod.rs index 24ba16a..de6c9d6 100644 --- a/packages/client-rust/src/utils/mod.rs +++ b/packages/client-rust/src/utils/mod.rs @@ -1,4 +1,4 @@ pub mod event; +pub mod rand; pub mod shell; pub mod task; -pub mod rand; \ No newline at end of file diff --git a/packages/client-rust/src/utils/task.rs b/packages/client-rust/src/utils/task.rs index 2bb9c0d..a881784 100644 --- a/packages/client-rust/src/utils/task.rs +++ b/packages/client-rust/src/utils/task.rs @@ -35,7 +35,7 @@ impl TaskManager { let mut tasks = self.tasks.lock().await; if let Some(handles) = tasks.remove(tag) { for handle in handles { - let _ = handle.abort(); + handle.abort(); } } }