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