| 121 | class AsyncDataSource : public DataSource<T> { |
| 122 | public: |
| 123 | explicit AsyncDataSource(std::unique_ptr<DataSource<T>> source) { |
| 124 | task = std::make_shared<DataTask<T>>(std::move(source)); |
| 125 | Task::Run(task); |
| 126 | } |
| 127 | |
| 128 | ~AsyncDataSource() override { |
| 129 | task->cancel(); |
nothing calls this directly
no outgoing calls
no test coverage detected