| 6 | |
| 7 | #[async_trait::async_trait] |
| 8 | pub trait Process: Send + Sync { |
| 9 | async fn send(&mut self, data: &str) -> Result<(), Box<dyn Error + Send + Sync>>; |
| 10 | async fn receive(&self) -> Result<String, Box<dyn Error + Send + Sync>>; |
| 11 | } |
| 12 | |
| 13 | #[derive(Clone)] |
| 14 | pub struct ProcessHandler { |
nothing calls this directly
no outgoing calls
no test coverage detected