diff --git a/src/runtime2/inbox.rs b/src/runtime2/inbox.rs index 1c952c4c4c63f30f108ca3580e208026d69be1a1..d3d822a5121b0856daf4a64968aec3ec3b579487 100644 --- a/src/runtime2/inbox.rs +++ b/src/runtime2/inbox.rs @@ -6,7 +6,6 @@ use crate::runtime2::consensus::{ComponentPresence, SolutionCombiner}; use crate::runtime2::port::ChannelId; use super::ConnectorId; -use super::branch::BranchId; use super::consensus::{GlobalSolution, LocalSolution}; use super::port::PortIdLocal; @@ -232,4 +231,9 @@ impl PublicInbox { let lock = self.messages.lock().unwrap(); return lock.is_empty(); } + + pub fn clear(&self) { + let mut lock = self.messages.lock().unwrap(); + lock.clear(); + } } \ No newline at end of file