void add_stream_from_serialized(const StreamProto &stream);
// Adds the given data to all the servers.
void set_header(const std::string &stream_id, const std::string &header);
void add_data(const std::string &stream_id, const char *data, size_t bytes);
void add_stream_from_serialized(const StreamProto &stream);
// Adds the given data to all the servers.
void set_header(const std::string &stream_id, const std::string &header);
void add_data(const std::string &stream_id, const char *data, size_t bytes);