| 148 | } |
| 149 | |
| 150 | bool WsPluginServer::PostTargetFileTransferMessage(const std::string& stream_id, std::shared_ptr<Data> msg) { |
| 151 | bool found_target_stream = false; |
| 152 | ft_routers_.ApplyAll([=, &found_target_stream](const uint64_t& socket_fd, const std::shared_ptr<WsFileTransferRouter>& router) { |
| 153 | if (stream_id == router->stream_id_ || stream_id.empty()) { |
| 154 | router->PostBinaryMessage(msg); |
| 155 | found_target_stream = true; |
| 156 | } |
| 157 | }); |
| 158 | return found_target_stream; |
| 159 | } |
| 160 | |
| 161 | int WsPluginServer::GetConnectedClientsCount() { |
| 162 | return (int)stream_routers_.Size(); |
no test coverage detected