Searched defs:map_observer (Results 1 – 1 of 1) sorted by relevance
55 struct map_observer struct57 typedef map_observer<Subscriber> this_type;58 typedef decltype((*(select_type*)nullptr)(*(source_value_type*)nullptr)) value_type;59 typedef rxu::decay_t<Subscriber> dest_type;60 typedef observer<source_value_type, this_type> observer_type;61 dest_type dest;62 mutable select_type selector;64 map_observer(dest_type d, select_type s) in map_observer() argument70 void on_next(Value&& v) const { in on_next()80 void on_error(rxu::error_ptr e) const { in on_error()[all …]