| 79 | } |
| 80 | |
| 81 | void WsPlugin::PostProtoMessage(std::shared_ptr<Data> msg, bool run_through) { |
| 82 | if (IsWorking() && HasConnectedClients() && msg) { |
| 83 | plugin_context_->PostWorkTask([=, this]() { |
| 84 | ws_server_->PostNetMessage(msg); |
| 85 | }); |
| 86 | } |
| 87 | } |
| 88 | |
| 89 | bool WsPlugin::PostTargetStreamProtoMessage(const std::string& stream_id, std::shared_ptr<Data> msg, bool run_through) { |
| 90 | if (IsWorking() && HasConnectedClients() && msg) { |
no test coverage detected