| 58 | */ |
| 59 | template<constraint::decayed_type Type, constraint::on_subscribe<Type> OnSubscribe> |
| 60 | auto create(OnSubscribe&& on_subscribe) |
| 61 | { |
| 62 | return create_observable<Type, std::decay_t<OnSubscribe>>{std::forward<OnSubscribe>(on_subscribe)}; |
| 63 | } |
| 64 | |
| 65 | /** |
| 66 | * @brief Construct observable specialized with passed callback function. Most easiesest way to construct observable "on the fly" via lambda and etc. |
nothing calls this directly
no outgoing calls
no test coverage detected