Searched defs:buffer_with_time_or_count_observer (Results 1 – 1 of 1) sorted by relevance
77 struct buffer_with_time_or_count_observer struct79 typedef buffer_with_time_or_count_observer<Subscriber> this_type;80 typedef std::vector<T> value_type;81 typedef rxu::decay_t<Subscriber> dest_type;82 typedef observer<value_type, this_type> observer_type;84 struct buffer_with_time_or_count_subscriber_values : public buffer_with_time_or_count_values102 typedef std::shared_ptr<buffer_with_time_or_count_subscriber_values> state_type;103 state_type state;105 …buffer_with_time_or_count_observer(composite_subscription cs, dest_type d, buffer_with_time_or_cou… in buffer_with_time_or_count_observer() argument142 …ble&)> produce_buffer(int id, rxsc::scheduler::clock_type::time_point expected, state_type state) { in produce_buffer()[all …]