thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-29 11:02:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Better comment

Browse Source
This commit is contained in:
alesapin 2020-10-27 15:50:43 +03:00
parent 3824fcb076
commit db16942716
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/IO/ReadWriteBufferFromHTTP.h
View File

@ -155,6 +155,7 @@ namespace detail
} }
public: public:
using NextReadCallback = std::function<void(size_t)>;
using OutStreamCallback = std::function<void(std::ostream &)>; using OutStreamCallback = std::function<void(std::ostream &)>;
explicit ReadWriteBufferFromHTTPBase( explicit ReadWriteBufferFromHTTPBase(
@ -222,9 +223,14 @@ namespace detail
return def; return def;
} }
void setNextReadCallback(std::function<void(size_t)> read_callback_) /// Set function to call on each nextImpl, useful when you need to track
/// progress.
/// NOTE: parameter on each call is not incremental -- it's all bytes count
/// passed through the buffer
void setNextReadCallback(NextReadCallback read_callback_)
{ {
read_callback = read_callback_; read_callback = read_callback_;
/// Some data maybe already read
read_callback(count()); read_callback(count());
} }
}; };