diff options
author | crupest <crupest@outlook.com> | 2024-10-06 13:57:39 +0800 |
---|---|---|
committer | crupest <crupest@outlook.com> | 2024-10-06 13:57:39 +0800 |
commit | dfe62dcf8bcefc523b466e127c3edc4dc2756629 (patch) | |
tree | 1c751a14ba0da07ca2ff805633f97568060aa4c9 /include/cru/base/io/ProxyStream.h | |
parent | f51eb955e188858272230a990565931e7403f23b (diff) | |
download | cru-dfe62dcf8bcefc523b466e127c3edc4dc2756629.tar.gz cru-dfe62dcf8bcefc523b466e127c3edc4dc2756629.tar.bz2 cru-dfe62dcf8bcefc523b466e127c3edc4dc2756629.zip |
Rename common to base.
Diffstat (limited to 'include/cru/base/io/ProxyStream.h')
-rw-r--r-- | include/cru/base/io/ProxyStream.h | 42 |
1 files changed, 42 insertions, 0 deletions
diff --git a/include/cru/base/io/ProxyStream.h b/include/cru/base/io/ProxyStream.h new file mode 100644 index 00000000..42ec9dfd --- /dev/null +++ b/include/cru/base/io/ProxyStream.h @@ -0,0 +1,42 @@ +#pragma once + +#include "Stream.h" + +#include <functional> + +namespace cru::io { +struct ProxyStreamHandlers { + std::function<Index(Index offset, Stream::SeekOrigin origin)> seek; + std::function<Index(std::byte* buffer, Index offset, Index size)> read; + std::function<Index(const std::byte* buffer, Index offset, Index size)> write; + std::function<void()> flush; + + /** + * @brief This method will be only called once when `Close` is called or the + * stream is destructed. + */ + std::function<void()> close; +}; + +class ProxyStream : public Stream { + public: + explicit ProxyStream(ProxyStreamHandlers handlers); + + ~ProxyStream() override; + + public: + CRU_STREAM_IMPLEMENT_CLOSE_BY_DO_CLOSE + + protected: + Index DoSeek(Index offset, SeekOrigin origin) override; + Index DoRead(std::byte* buffer, Index offset, Index size) override; + Index DoWrite(const std::byte* buffer, Index offset, Index size) override; + void DoFlush() override; + + private: + void DoClose(); + + private: + ProxyStreamHandlers handlers_; +}; +} // namespace cru::io |