Searched defs:group_by_observable (Results 1 – 1 of 1) sorted by relevance
156 struct group_by_observable : public rxs::source_base<marble_type> struct158 mutable std::shared_ptr<group_by_state_type> state;159 subject_type subject;160 key_type key;162 group_by_observable(std::shared_ptr<group_by_state_type> st, subject_type s, key_type k) in group_by_observable() argument170 void on_subscribe(Subscriber&& o) const { in on_subscribe()175 key_type on_get_key() { in on_get_key()