Searched refs:reader_ (Results 1 – 2 of 2) sorted by relevance
28 if (reader_.joinable()) { in AddSubscriber()35 reader_ = std::thread([this, source]() { in Start()74 if (reader_.joinable()) { in Join()75 reader_.join(); in Join()
44 std::thread reader_; variable