| 321 | template<typename Subscribe> |
| 322 | requires rpp::utils::is_base_of_v<std::decay_t<Subscribe>, rpp::operators::details::subscribe_t> |
| 323 | auto operator|(Subscribe&& op) const |
| 324 | { |
| 325 | return std::forward<Subscribe>(op)(*this); |
| 326 | } |
| 327 | |
| 328 | template<typename Op> |
| 329 | requires (!rpp::utils::is_base_of_v<std::decay_t<Op>, rpp::operators::details::subscribe_t>) |
nothing calls this directly
no outgoing calls
no test coverage detected