From dfe62dcf8bcefc523b466e127c3edc4dc2756629 Mon Sep 17 00:00:00 2001
From: crupest <crupest@outlook.com>
Date: Sun, 6 Oct 2024 13:57:39 +0800
Subject: Rename common to base.

---
 src/base/io/ProxyStream.cpp | 37 +++++++++++++++++++++++++++++++++++++
 1 file changed, 37 insertions(+)
 create mode 100644 src/base/io/ProxyStream.cpp

(limited to 'src/base/io/ProxyStream.cpp')

diff --git a/src/base/io/ProxyStream.cpp b/src/base/io/ProxyStream.cpp
new file mode 100644
index 00000000..de66169e
--- /dev/null
+++ b/src/base/io/ProxyStream.cpp
@@ -0,0 +1,37 @@
+#include "cru/base/io/ProxyStream.h"
+#include "cru/base/io/Stream.h"
+
+namespace cru::io {
+ProxyStream::ProxyStream(ProxyStreamHandlers handlers)
+    : Stream(static_cast<bool>(handlers.seek), static_cast<bool>(handlers.read),
+             static_cast<bool>(handlers.write)),
+      handlers_(std::move(handlers)) {}
+
+ProxyStream::~ProxyStream() { DoClose(); }
+
+Index ProxyStream::DoSeek(Index offset, SeekOrigin origin) {
+  return handlers_.seek(offset, origin);
+}
+
+Index ProxyStream::DoRead(std::byte* buffer, Index offset, Index size) {
+  return handlers_.read(buffer, offset, size);
+}
+
+Index ProxyStream::DoWrite(const std::byte* buffer, Index offset, Index size) {
+  return handlers_.write(buffer, offset, size);
+}
+
+void ProxyStream::DoFlush() {
+  if (handlers_.flush) {
+    handlers_.flush();
+  }
+}
+
+void ProxyStream::DoClose() {
+  CRU_STREAM_BEGIN_CLOSE
+  if (handlers_.close) {
+    handlers_.close();
+  }
+  handlers_ = {};
+}
+}  // namespace cru::io
-- 
cgit v1.2.3