Searched defs:window_with_time_observer (Results 1 – 1 of 1) sorted by relevance
87 struct window_with_time_observer struct89 typedef window_with_time_observer<Subscriber> this_type;90 typedef rxu::decay_t<T> value_type;91 typedef rxu::decay_t<Subscriber> dest_type;92 typedef observer<T, this_type> observer_type;94 struct window_with_time_subscriber_values : public window_with_time_values112 std::shared_ptr<window_with_time_subscriber_values> state;114 …window_with_time_observer(composite_subscription cs, dest_type d, window_with_time_values v, coord… in window_with_time_observer() argument182 void on_next(T v) const { in on_next()198 void on_error(rxu::error_ptr e) const { in on_error()[all …]