| 26 | StreamThread() : stop(false), thread(&StreamThread::thread_fn, this) {} |
| 27 | |
| 28 | ~StreamThread() { |
| 29 | { |
| 30 | std::lock_guard<std::mutex> lk(mtx); |
| 31 | stop = true; |
| 32 | } |
| 33 | cond.notify_one(); |
| 34 | thread.join(); |
| 35 | } |
| 36 | |
| 37 | void thread_fn() { |
| 38 | while (true) { |
nothing calls this directly
no outgoing calls
no test coverage detected