ReactivePlusPlus
One more implementation of ReactiveX approach in C++ with care about performance and templates in mind
 
Loading...
Searching...
No Matches
rpp::grouped_observable< KeyType, Type, OnSubscribeFn > Class Template Reference
Inheritance diagram for rpp::grouped_observable< KeyType, Type, OnSubscribeFn >:
rpp::specific_observable< Type, OnSubscribeFn > rpp::interface_observable< Type, specific_observable< Type, OnSubscribeFn > > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::member_overload< Type, SpecificObservable, MemberTag > rpp::details::typed_observable_tag< Type >

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_observableoperator= (const specific_observable &other)=default
 
specific_observableoperator= (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 () &&
 

The documentation for this class was generated from the following files: