Searched defs:sample_with_time_observer (Results 1 – 1 of 1) sorted by relevance
69 struct sample_with_time_observer struct71 typedef sample_with_time_observer<Subscriber> this_type;72 typedef T value_type;73 typedef rxu::decay_t<Subscriber> dest_type;74 typedef observer<value_type, this_type> observer_type;76 struct sample_with_time_subscriber_value : public sample_with_time_value92 std::shared_ptr<sample_with_time_subscriber_value> state;94 …sample_with_time_observer(composite_subscription cs, dest_type d, sample_with_time_value v, coordi… in sample_with_time_observer() argument139 void on_next(T v) const { in on_next()153 void on_error(rxu::error_ptr e) const { in on_error()[all …]