Searched defs:timestamp_observer (Results 1 – 1 of 1) sorted by relevance
63 struct timestamp_observer struct65 typedef timestamp_observer<Subscriber> this_type;66 typedef source_value_type value_type;67 typedef rxu::decay_t<Subscriber> dest_type;68 typedef observer<value_type, this_type> observer_type;69 dest_type dest;70 coordination_type coord;72 timestamp_observer(dest_type d, coordination_type coordination) in timestamp_observer() function78 void on_next(source_value_type v) const { in on_next()81 void on_error(rxu::error_ptr e) const { in on_error()[all …]