Searched defs:element_at_observer (Results 1 – 1 of 1) sorted by relevance
59 struct element_at_observer : public element_at_values struct61 typedef element_at_observer<Subscriber> this_type;62 typedef source_value_type value_type;63 typedef rxu::decay_t<Subscriber> dest_type;64 typedef observer<value_type, this_type> observer_type;65 dest_type dest;66 mutable int current;68 element_at_observer(dest_type d, element_at_values v) in element_at_observer() argument74 void on_next(source_value_type v) const { in on_next()80 void on_error(rxu::error_ptr e) const { in on_error()[all …]