| 69 | |
| 70 | public: |
| 71 | static std::shared_ptr<BackgroundReader> StartReader(int fd) { |
| 72 | std::shared_ptr<BackgroundReader> reader(new BackgroundReader(fd)); |
| 73 | reader->worker_.reset(new std::thread([=] { reader->LoopReading(); })); |
| 74 | return reader; |
| 75 | } |
| 76 | void Stop() { ARROW_CHECK(SetEvent(event_)); } |
| 77 | void Join() { worker_->join(); } |
| 78 |
nothing calls this directly
no test coverage detected