| 813 | } |
| 814 | |
| 815 | void waitForComplete() { |
| 816 | for (auto &future : futures) { |
| 817 | future.get(); |
| 818 | } |
| 819 | |
| 820 | // free all RawTransaction memory slots |
| 821 | finishedQueue.consume_all([](RawTransaction *tx) { |
| 822 | delete tx; |
| 823 | }); |
| 824 | } |
| 825 | }; |
| 826 | |
| 827 | NewBlocksFiles::NewBlocksFiles(const ParserConfigurationBase &config) : |