Searched refs:stopsource (Results 1 – 1 of 1) sorted by relevance
121 static void stopsource(Subscriber&& dest, std::shared_ptr<group_by_state_type>& state) { in stopsource() function171 group_by::stopsource(o, state); in on_subscribe()197 group_by::stopsource(dest, state); in group_by_observer()