(&self)
| 211 | } |
| 212 | |
| 213 | pub async fn connected(&self) -> Vec<ConnectedInspector> { |
| 214 | self.inner |
| 215 | .lock() |
| 216 | .await |
| 217 | .agents |
| 218 | .iter() |
| 219 | .filter(|(_, agent)| !agent.info.is_null()) |
| 220 | .map(|(process_identifier, agent)| ConnectedInspector { |
| 221 | process_identifier: *process_identifier, |
| 222 | info: agent.info.clone(), |
| 223 | }) |
| 224 | .collect() |
| 225 | } |
| 226 | |
| 227 | pub async fn published_inspectors(&self) -> Vec<PublishedInspector> { |
| 228 | let Some(registry) = self.registry.as_ref() else { |
no test coverage detected