Searched defs:buffer_with_time_observer (Results 1 – 1 of 1) sorted by relevance
95 struct buffer_with_time_observer struct97 typedef buffer_with_time_observer<Subscriber> this_type;98 typedef std::vector<T> value_type;99 typedef rxu::decay_t<Subscriber> dest_type;100 typedef observer<value_type, this_type> observer_type;102 struct buffer_with_time_subscriber_values : public buffer_with_time_values120 std::shared_ptr<buffer_with_time_subscriber_values> state;122 …buffer_with_time_observer(composite_subscription cs, dest_type d, buffer_with_time_values v, coord… in buffer_with_time_observer() function185 void on_next(T v) const { in on_next()200 void on_error(rxu::error_ptr e) const { in on_error()[all …]