Public Member Functions | |
grouped_observable (KeyType key, const OnSubscribeFn &on_subscribe) | |
grouped_observable (KeyType key, OnSubscribeFn &&on_subscribe) | |
const KeyType & | get_key () const |
Public Member Functions inherited from rpp::specific_observable< Type, OnSubscribeFn > | |
specific_observable (OnSubscribeFn &&on_subscribe) | |
specific_observable (const OnSubscribeFn &on_subscribe) | |
specific_observable (const specific_observable &other)=default | |
specific_observable (specific_observable &&other) noexcept=default | |
specific_observable & | operator= (const specific_observable &other)=default |
specific_observable & | operator= (specific_observable &&other) noexcept=default |
template<typename... Args> requires details::is_header_included<details::dynamic_observable_tag, Args...> | |
auto | as_dynamic () const & |
Converts rpp::specific_observable to rpp::dynamic_observable via type-erasure mechanism. | |
template<typename... Args> requires details::is_header_included<details::dynamic_observable_tag, Args...> | |
auto | as_dynamic () && |
Public Member Functions inherited from rpp::interface_observable< Type, specific_observable< Type, OnSubscribeFn > > | |
auto | op (OperatorFn &&fn) const & |
The apply function to observable which returns observable of another type. | |
auto | op (OperatorFn &&fn) && |
auto | as_blocking () const & |
Converts existing observable to rpp::blocking_observable which has another interface and abilities. | |
auto | as_blocking () && |