| 137 | } |
| 138 | |
| 139 | bool WsPluginServer::PostTargetStreamMessage(const std::string& stream_id, std::shared_ptr<Data> msg) { |
| 140 | bool found_target_stream = false; |
| 141 | stream_routers_.ApplyAll([=, &found_target_stream](const uint64_t& socket_fd, const std::shared_ptr<WsStreamRouter>& router) { |
| 142 | if (stream_id == router->stream_id_ || stream_id.empty()) { |
| 143 | router->PostBinaryMessage(msg); |
| 144 | found_target_stream = true; |
| 145 | } |
| 146 | }); |
| 147 | return found_target_stream; |
| 148 | } |
| 149 | |
| 150 | bool WsPluginServer::PostTargetFileTransferMessage(const std::string& stream_id, std::shared_ptr<Data> msg) { |
| 151 | bool found_target_stream = false; |
no test coverage detected