Searched defs:timeout_observer (Results 1 – 1 of 1) sorted by relevance
78 struct timeout_observer struct80 typedef timeout_observer<Subscriber> this_type;81 typedef rxu::decay_t<T> value_type;82 typedef rxu::decay_t<Subscriber> dest_type;83 typedef observer<T, this_type> observer_type;85 struct timeout_subscriber_values : public timeout_values103 typedef std::shared_ptr<timeout_subscriber_values> state_type;104 state_type state;106 … timeout_observer(composite_subscription cs, dest_type d, timeout_values v, coordinator_type c) in timeout_observer() function145 …c std::function<void(const rxsc::schedulable&)> produce_timeout(std::size_t id, state_type state) { in produce_timeout()[all …]