| 32 | } |
| 33 | |
| 34 | void RemoteBlockInputStream::init() |
| 35 | { |
| 36 | query_executor.setProgressCallback([this](const Progress & progress) { progressImpl(progress); }); |
| 37 | query_executor.setProfileInfoCallback([this](const BlockStreamProfileInfo & info_) { info.setFrom(info_, true); }); |
| 38 | query_executor.setLogger(log); |
| 39 | } |
| 40 | |
| 41 | void RemoteBlockInputStream::readPrefix() |
| 42 | { |