streams.insert(make_pair(stream.stream_id(), new Stream(stream)));
}
+void Server::set_backlog_size(const std::string &stream_id, size_t new_size)
+{
+ MutexLock lock(&mutex);
+ assert(streams.count(stream_id) != 0);
+ streams[stream_id]->set_backlog_size(new_size);
+}
+
void Server::set_header(const string &stream_id, const string &header)
{
MutexLock lock(&mutex);
++queued_it) {
Stream *stream = find_stream(queued_it->first);
stream->add_data(queued_it->second.data(), queued_it->second.size());
+ stream->wake_up_all_clients();
}
queued_data.clear();
}