Searched defs:skip_while_observer (Results 1 – 1 of 1) sorted by relevance
55 struct skip_while_observer struct57 typedef skip_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;63 bool pass;65 skip_while_observer(dest_type d, test_type t) in skip_while_observer() function71 void on_next(source_value_type v) { in on_next()[all …]