Searched refs: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; argument192 group_by_observer(composite_subscription l, dest_type d, group_by_values v) in group_by_observer() function274 -> decltype(group_by_observer<Subscriber>::make(std::move(dest), initial)) { in operator ()()275 return group_by_observer<Subscriber>::make(std::move(dest), initial); in operator ()()