| 353 | } |
| 354 | |
| 355 | std::shared_ptr<remote_subscription> eventgroupinfo::get_remote_subscription(const remote_subscription_id_t _id) { |
| 356 | std::scoped_lock its_lock(subscriptions_mutex_); |
| 357 | |
| 358 | auto find_subscription = subscriptions_.find(_id); |
| 359 | if (find_subscription != subscriptions_.end()) |
| 360 | return find_subscription->second; |
| 361 | |
| 362 | return nullptr; |
| 363 | } |
| 364 | |
| 365 | void eventgroupinfo::remove_remote_subscription(const remote_subscription_id_t _id) { |
| 366 | std::scoped_lock its_lock(subscriptions_mutex_); |
no test coverage detected