| 97 | AsyncTablesHandler(); |
| 98 | ~AsyncTablesHandler() {} |
| 99 | void AddAsyncRpcHandler(std::shared_ptr<TableHandler> handler, const std::vector<size_t>& pos_info) { |
| 100 | handlers_.push_back(handler); |
| 101 | posinfos_.push_back(pos_info); |
| 102 | rows_cnt_ += pos_info.size(); |
| 103 | } |
| 104 | const uint64_t GetCount() override { |
| 105 | if (status_.isRunning()) { |
| 106 | SyncAllTableHandlers(); |