| 169 | std::string InputStream::get_notify() { return notify_; } |
| 170 | |
| 171 | void InputStream::clear_queue() { |
| 172 | Packet pkt; |
| 173 | while (not queue_->empty()) { |
| 174 | queue_->pop(pkt); |
| 175 | } |
| 176 | } |
| 177 | |
| 178 | bool InputStream::get_min_timestamp(int64_t &min_timestamp) { |
| 179 | if (queue_->empty()) { |