#pragma once #include #include namespace DB { /// Reads data with HTTP Chunked Transfer Encoding. class HTTPChunkedReadBuffer : public BufferWithOwnMemory { public: HTTPChunkedReadBuffer(std::unique_ptr in_, size_t max_chunk_size) : in(std::move(in_)), max_size(max_chunk_size) {} private: std::unique_ptr in; const size_t max_size; size_t readChunkHeader(); void readChunkFooter(); bool nextImpl() override; }; }