| 280 | } |
| 281 | |
| 282 | bool remote_subscription::is_forwarded() const { |
| 283 | return this->final_destination_.load(std::memory_order_acquire) == destiny::forward; |
| 284 | } |
| 285 | |
| 286 | void remote_subscription::set_forwarded() { |
| 287 | this->final_destination_.store(destiny::forward, std::memory_order_release); |
no test coverage detected