(self)
| 152 | } |
| 153 | |
| 154 | async fn shutdown(self) { |
| 155 | self.shutdown_bus.initiate(); |
| 156 | let _ = self.poller_shutdown_tx.send(true); |
| 157 | let _ = self.core_stop_tx.send(()); |
| 158 | tokio::time::sleep(Duration::from_millis(50)).await; |
| 159 | } |
| 160 | } |
| 161 | |
| 162 | // ─── Helpers ──────────────────────────────────────────────────────────────── |
no test coverage detected