Searched defs:take_while_observer (Results 1 – 1 of 1) sorted by relevance
55 struct take_while_observer struct57 typedef take_while_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;61 dest_type dest;62 test_type test;64 take_while_observer(dest_type d, test_type t) in take_while_observer() function69 void on_next(source_value_type v) const { in on_next()76 void on_error(rxu::error_ptr e) const { in on_error()[all …]