(&self)
| 135 | /// contention (`tokio::sync::watch` semantics). |
| 136 | #[must_use] |
| 137 | pub fn subscribe(&self) -> watch::Receiver<HealthState> { |
| 138 | self.receiver.clone() |
| 139 | } |
| 140 | |
| 141 | /// Wait until the monitor publishes its first non-`Initializing` state. |
| 142 | /// |
no outgoing calls
no test coverage detected