(&mut self)
| 147 | /// call this before constructing the router. |
| 148 | #[cfg(test)] |
| 149 | pub(crate) async fn wait_until_polled(&mut self) { |
| 150 | while matches!(*self.receiver.borrow(), HealthState::Initializing) { |
| 151 | if self.receiver.changed().await.is_err() { |
| 152 | return; |
| 153 | } |
| 154 | } |
| 155 | } |
| 156 | } |
| 157 | |
| 158 | async fn monitor_loop( |
no outgoing calls
no test coverage detected