| 288 | } |
| 289 | |
| 290 | void remote_subscription::clear_destiny() { |
| 291 | this->final_destination_.store(destiny::none, std::memory_order_release); |
| 292 | } |
| 293 | |
| 294 | std::shared_ptr<remote_subscription> remote_subscription::get_parent_or_self() { |
| 295 | // check if parent subscription exists, if so return it, otherwise return the subscription itself to be used for checking pending |