From 313058e70a15862c34b673b1bd552518cef11055 Mon Sep 17 00:00:00 2001 From: Alex Clarke Date: Wed, 18 Feb 2026 09:13:39 -0700 Subject: [PATCH] refactor: Cleaned up some left-over implementation stubs --- src/supervisor/mailbox.rs | 4 ---- src/supervisor/mod.rs | 13 ------------- src/supervisor/taskqueue.rs | 4 ---- 3 files changed, 21 deletions(-) diff --git a/src/supervisor/mailbox.rs b/src/supervisor/mailbox.rs index 6c63e84..e0853f3 100644 --- a/src/supervisor/mailbox.rs +++ b/src/supervisor/mailbox.rs @@ -48,10 +48,6 @@ impl Inbox { msgs } - - pub fn pending_count(&self) -> usize { - self.messages.lock().len() - } } impl Clone for Inbox { diff --git a/src/supervisor/mod.rs b/src/supervisor/mod.rs index cdd6c6b..a120b26 100644 --- a/src/supervisor/mod.rs +++ b/src/supervisor/mod.rs @@ -15,7 +15,6 @@ use tokio::task::JoinHandle; #[derive(Debug, Clone, PartialEq, Eq)] pub enum AgentExitStatus { Completed, - Cancelled, Failed(String), } @@ -95,18 +94,6 @@ impl Supervisor { self.handles.get(id).map(|h| h.join_handle.is_finished()) } - pub fn take_if_finished(&mut self, id: &str) -> Option { - if self - .handles - .get(id) - .is_some_and(|h| h.join_handle.is_finished()) - { - self.handles.remove(id) - } else { - None - } - } - pub fn take(&mut self, id: &str) -> Option { self.handles.remove(id) } diff --git a/src/supervisor/taskqueue.rs b/src/supervisor/taskqueue.rs index 8c234f3..6387122 100644 --- a/src/supervisor/taskqueue.rs +++ b/src/supervisor/taskqueue.rs @@ -150,10 +150,6 @@ impl TaskQueue { false } - pub fn runnable_tasks(&self) -> Vec<&TaskNode> { - self.tasks.values().filter(|t| t.is_runnable()).collect() - } - pub fn get(&self, task_id: &str) -> Option<&TaskNode> { self.tasks.get(task_id) }