Searched defs:delay_observer (Results 1 – 1 of 1) sorted by relevance
69 struct delay_observer struct71 typedef delay_observer<Subscriber> this_type;72 typedef rxu::decay_t<T> value_type;73 typedef rxu::decay_t<Subscriber> dest_type;74 typedef observer<T, this_type> observer_type;76 struct delay_subscriber_values : public delay_values93 std::shared_ptr<delay_subscriber_values> state;95 delay_observer(composite_subscription cs, dest_type d, delay_values v, coordinator_type c) in delay_observer() argument120 void on_next(T v) const { in on_next()134 void on_error(rxu::error_ptr e) const { in on_error()[all …]