Searched defs:distinct_until_changed_observer (Results 1 – 1 of 1) sorted by relevance
55 struct distinct_until_changed_observer struct57 typedef distinct_until_changed_observer<Subscriber> this_type;58 typedef source_value_type value_type;59 typedef rxu::decay_t<Subscriber> dest_type;60 typedef observer<value_type, this_type> observer_type;62 dest_type dest;63 predicate_type pred;64 mutable rxu::detail::maybe<source_value_type> remembered;66 distinct_until_changed_observer(dest_type d, predicate_type pred) in distinct_until_changed_observer() argument71 void on_next(source_value_type v) const { in on_next()[all …]