Searched defs:synchronize_observer_state (Results 1 – 1 of 1) sorted by relevance
26 …struct synchronize_observer_state : public std::enable_shared_from_this<synchronize_observer_state> struct in rxcpp::subjects::detail::synchronize_observer28 typedef rxn::notification<T> notification_type;29 typedef typename notification_type::type base_notification_type;30 typedef std::deque<base_notification_type> queue_type;32 struct mode42 mutable std::mutex lock;43 mutable std::condition_variable wake;44 mutable queue_type fill_queue;45 composite_subscription lifetime;46 mutable typename mode::type current;[all …]