Searched refs:subscribers_ (Results 1 – 7 of 7) sorted by relevance
99 subscribers_.erase(old_endpoint); in handle_control_request_timer()107 subscribers_.insert(new_endpoint); in handle_control_request_timer()136 for (j = subscribers_.begin(); j != subscribers_.end(); ++j) in handle_timer()161 std::set<udp::endpoint> subscribers_; member in server
50 subscribers_.insert(subscriber); in join()55 subscribers_.erase(subscriber); in leave()60 std::for_each(subscribers_.begin(), subscribers_.end(), in deliver()66 std::set<subscriber_ptr> subscribers_; member in channel
48 subscribers_.insert(subscriber); in join()53 subscribers_.erase(subscriber); in leave()58 for (const auto& s : subscribers_) in deliver()65 std::set<subscriber_ptr> subscribers_; member in channel
36 subscribers_.insert( s); in subscribe()41 subscribers_.erase(s); in unsubscribe()49 std::set< subscriber_session_ptr > subscribers_; member in subscriptions221 for ( subscriber_session_ptr s : subscribers_) { in ~subscriptions()228 for ( subscriber_session_ptr s : subscribers_) { in publish()