Searched defs:all_observer (Results 1 – 1 of 1) sorted by relevance
57 struct all_observer struct59 typedef all_observer<Subscriber> this_type;60 typedef source_value_type value_type;61 typedef rxu::decay_t<Subscriber> dest_type;62 typedef observer<value_type, this_type> observer_type;63 dest_type dest;64 test_type test;65 mutable bool done;67 all_observer(dest_type d, test_type t) in all_observer() argument73 void on_next(source_value_type v) const { in on_next()[all …]