Searched defs:filter_observer (Results 1 – 2 of 2) sorted by relevance
54 struct filter_observer struct56 typedef filter_observer<Subscriber> this_type;57 typedef source_value_type value_type;58 typedef rxu::decay_t<Subscriber> dest_type;59 typedef observer<value_type, this_type> observer_type;60 dest_type dest;61 mutable test_type test;63 filter_observer(dest_type d, test_type t) in filter_observer() argument70 void on_next(Value&& v) const { in on_next()82 void on_error(rxu::error_ptr e) const { in on_error()[all …]
17 …struct filter_observer : public rx::observer_base<typename std::decay<Subscriber>::type::value_typ… struct19 typedef filter_observer<Subscriber> this_type;20 typedef rx::observer_base<typename std::decay<Subscriber>::type::value_type> base_type;21 typedef typename base_type::value_type value_type;22 typedef typename std::decay<Subscriber>::type dest_type;23 typedef rx::observer<value_type, this_type> observer_type;24 dest_type dest;25 test_type test;27 filter_observer(dest_type d, test_type t) in filter_observer() function32 void on_next(typename dest_type::value_type v) const { in on_next()[all …]