| 73 | } |
| 74 | |
| 75 | pub struct MessageMetadata { |
| 76 | pub(crate) aggregate_id: String, |
| 77 | pub(crate) topic: String, |
| 78 | } |
| 79 | |
| 80 | pub trait Aggregate: Send + Sync { |
| 81 | fn collect_events(&mut self) -> VecDeque<Box<dyn Message>> { |
nothing calls this directly
no outgoing calls
no test coverage detected