Searched defs:observe_on_state (Results 1 – 1 of 1) sorted by relevance
81 struct observe_on_state : std::enable_shared_from_this<observe_on_state> struct83 mutable std::mutex lock;84 mutable queue_type fill_queue;85 mutable queue_type drain_queue;86 composite_subscription lifetime;87 mutable typename mode::type current;88 coordinator_type coordinator;89 dest_type destination;91 observe_on_state(dest_type d, coordinator_type coor, composite_subscription cs) in observe_on_state() function99 void finish(std::unique_lock<std::mutex>& guard, typename mode::type end) const { in finish()[all …]