summaryrefslogtreecommitdiff
path: root/src/input-reader.hpp
diff options
context:
space:
mode:
authorVasile Vilvoiu <vasi@vilvoiu.ro>2021-07-21 18:33:51 +0300
committerVasile Vilvoiu <vasi@vilvoiu.ro>2021-07-21 18:33:51 +0300
commit270dfd60cde3a7b65a2654eef0f299f32ca704c4 (patch)
treec0afad3642995e6c29e3788e94098cbf73eb3211 /src/input-reader.hpp
parent1f59802058d1b8fbd51b9f01bd400625773e714f (diff)
Checks in base InputReader class.
Make InputReader::GetBuffer() a protected member.
Diffstat (limited to 'src/input-reader.hpp')
-rw-r--r--src/input-reader.hpp11
1 files changed, 8 insertions, 3 deletions
diff --git a/src/input-reader.hpp b/src/input-reader.hpp
index aac2640..3a98ef8 100644
--- a/src/input-reader.hpp
+++ b/src/input-reader.hpp
@@ -21,6 +21,8 @@ protected:
std::istream * const stream_;
const std::size_t block_size_bytes_;
+ virtual std::vector<char> GetBuffer() = 0;
+
public:
InputReader() = delete;
InputReader(const InputReader&) = delete;
@@ -32,19 +34,20 @@ public:
virtual bool ReachedEOF() const = 0;
virtual std::optional<std::vector<char>> GetBlock() = 0;
- virtual std::vector<char> GetBuffer() = 0;
};
/*
* Synchronous input reader
*/
class SyncInputReader : public InputReader {
+protected:
+ std::vector<char> GetBuffer() override;
+
public:
SyncInputReader(std::istream * stream, std::size_t block_size_bytes);
bool ReachedEOF() const override;
std::optional<std::vector<char>> GetBlock() override;
- std::vector<char> GetBuffer() override;
};
/*
@@ -65,13 +68,15 @@ private:
void Read();
+protected:
+ std::vector<char> GetBuffer() override;
+
public:
AsyncInputReader(std::istream * stream, std::size_t block_size_bytes);
~AsyncInputReader() override;
bool ReachedEOF() const override;
std::optional<std::vector<char>> GetBlock() override;
- std::vector<char> GetBuffer() override;
};
#endif