Searched defs:window_observer (Results 1 – 1 of 1) sorted by relevance
71 struct window_observer : public window_values struct73 typedef window_observer<Subscriber> this_type;74 typedef rxu::decay_t<T> value_type;75 typedef rxu::decay_t<Subscriber> dest_type;76 typedef observer<T, this_type> observer_type;77 dest_type dest;78 mutable int cursor;79 mutable std::deque<rxcpp::subjects::subject<T>> subj;81 window_observer(dest_type d, window_values v) in window_observer() function89 void on_next(T v) const { in on_next()[all …]