From a21be4edaa483b86872ad732fc4b93970a607952 Mon Sep 17 00:00:00 2001
From: crupest <crupest@outlook.com>
Date: Mon, 12 Feb 2024 15:47:31 +0800
Subject: WORKING: add Buffer and AutoReadStream.

---
 src/common/io/AutoReadStream.cpp | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)
 create mode 100644 src/common/io/AutoReadStream.cpp

(limited to 'src/common/io/AutoReadStream.cpp')

diff --git a/src/common/io/AutoReadStream.cpp b/src/common/io/AutoReadStream.cpp
new file mode 100644
index 00000000..7cdc1268
--- /dev/null
+++ b/src/common/io/AutoReadStream.cpp
@@ -0,0 +1,36 @@
+#include "cru/common/io/AutoReadStream.h"
+#include <vector>
+#include "cru/common/io/Stream.h"
+
+namespace cru::io {
+
+AutoReadStream::AutoReadStream(Stream* stream, bool auto_delete,
+                               const AutoReadStreamOptions& options) {
+  background_thread_ = std::thread(&AutoReadStream::BackgroundThreadRun, this);
+}
+
+bool AutoReadStream::CanSeek() { return false; }
+
+Index AutoReadStream::Seek(Index offset, SeekOrigin origin) {
+  throw StreamOperationNotSupportedException(
+      u"AutoReadStream does not support seek.");
+}
+
+bool AutoReadStream::CanWrite() { return stream_->CanWrite(); }
+
+Index AutoReadStream::Write(const std::byte* buffer, Index offset, Index size) {
+  return stream_->Write(buffer, offset, size);
+}
+
+void AutoReadStream::Flush() { stream_->Flush(); }
+
+void AutoReadStream::BackgroundThreadRun() {
+  std::unique_lock<std::mutex> lock(buffer_mutex_);
+  std::vector<std::byte>* buffer = nullptr;
+  if (!buffer_list_.empty()) {
+  }
+  stream_->Read();
+}
+}
+
+}  // namespace cru::io
-- 
cgit v1.2.3