Searched defs:finally_observer (Results 1 – 1 of 1) sorted by relevance
58 struct finally_observer struct60 typedef finally_observer<Subscriber> this_type;61 typedef source_value_type value_type;62 typedef rxu::decay_t<Subscriber> dest_type;63 typedef observer<value_type, this_type> observer_type;64 dest_type dest;66 finally_observer(dest_type d) in finally_observer() function70 void on_next(source_value_type v) const { in on_next()73 void on_error(rxu::error_ptr e) const { in on_error()76 void on_completed() const { in on_completed()[all …]