| 335 | } |
| 336 | |
| 337 | std::vector<std::shared_ptr<GrConnectedClientInfo>> WsPluginServer::GetConnectedClientInfo() { |
| 338 | std::vector<std::shared_ptr<GrConnectedClientInfo>> clients_info; |
| 339 | stream_routers_.VisitAll([&](const auto&, const std::shared_ptr<WsStreamRouter>& router) { |
| 340 | clients_info.push_back(std::make_shared<GrConnectedClientInfo>(GrConnectedClientInfo { |
| 341 | .device_id_ = router->visitor_device_id_, |
| 342 | .stream_id_ = router->stream_id_, |
| 343 | .device_name_ = router->device_name_, |
| 344 | })); |
| 345 | }); |
| 346 | return clients_info; |
| 347 | } |
| 348 | |
| 349 | void WsPluginServer::OnClientHello(const std::shared_ptr<MsgClientHello>& event) { |
| 350 | stream_routers_.VisitAll([&](const auto&, const std::shared_ptr<WsStreamRouter>& router) { |
nothing calls this directly
no outgoing calls
no test coverage detected