Searched defs:any_observer (Results 1 – 1 of 1) sorted by relevance
64 struct any_observer struct66 typedef any_observer<Subscriber> this_type;67 typedef source_value_type value_type;68 typedef rxu::decay_t<Subscriber> dest_type;69 typedef observer<value_type, this_type> observer_type;70 dest_type dest;71 test_type test;72 mutable bool done;74 any_observer(dest_type d, test_type t) in any_observer() argument80 void on_next(source_value_type v) const { in on_next()[all …]