Searched defs:pairwise_observer (Results 1 – 1 of 1) sorted by relevance
48 struct pairwise_observer struct50 typedef pairwise_observer<Subscriber> this_type;51 typedef std::tuple<source_value_type, source_value_type> value_type;52 typedef rxu::decay_t<Subscriber> dest_type;53 typedef observer<T, this_type> observer_type;54 dest_type dest;55 mutable rxu::detail::maybe<source_value_type> remembered;57 pairwise_observer(dest_type d) in pairwise_observer() function61 void on_next(source_value_type v) const { in on_next()70 void on_error(rxu::error_ptr e) const { in on_error()[all …]