Searched defs:group_by_observer (Results 1 – 1 of 1) sorted by relevance
181 struct group_by_observer : public group_by_values struct183 typedef group_by_observer<Subscriber> this_type;184 typedef typename traits_type::grouped_observable_type value_type;185 typedef rxu::decay_t<Subscriber> dest_type;186 typedef observer<T, this_type> observer_type;188 dest_type dest;190 mutable std::shared_ptr<group_by_state_type> state;192 group_by_observer(composite_subscription l, dest_type d, group_by_values v) in group_by_observer() function199 void on_next(T v) const { in on_next()253 void on_error(rxu::error_ptr e) const { in on_error()[all …]