Searched defs:distinct_observer (Results 1 – 1 of 1) sorted by relevance
45 struct distinct_observer struct47 typedef distinct_observer<Subscriber> this_type;48 typedef source_value_type value_type;49 typedef rxu::decay_t<Subscriber> dest_type;50 typedef observer<value_type, this_type> observer_type;51 dest_type dest;52 … mutable std::unordered_set<source_value_type, rxcpp::filtered_hash<source_value_type>> remembered;54 distinct_observer(dest_type d) in distinct_observer() argument58 void on_next(source_value_type v) const { in on_next()64 void on_error(rxu::error_ptr e) const { in on_error()[all …]