36 void remove(std::shared_ptr<Client> client);
38 void add_reader(
const std::string& channel,
const std::string& type,
39 std::shared_ptr<Client> client);
40 void add_writer(
const std::string& channel,
const std::string& type,
41 std::shared_ptr<Client> client);
43 void publish(
const std::string& channel,
const std::string& data);
46 std::unique_ptr<apollo::cyber::Node> node;
55 std::unordered_set<std::shared_ptr<Client>> clients;
62 std::unordered_set<std::shared_ptr<Client>> clients;
65 typedef std::unordered_map<std::string, Writer> Writers;
66 typedef std::unordered_map<std::string, Reader> Readers;