intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 30 insertions, 0 deletions

diff --git a/util/stream/aligned.cpp b/util/stream/aligned.cpp
new file mode 100644
index 0000000000..2fd12d15b7
--- /dev/null
+++ b/util/stream/aligned.cpp
@@ -0,0 +1,30 @@
+#include "aligned.h"
+
+size_t TAlignedInput::DoRead(void* ptr, size_t len) {
+    size_t ret = Stream_->Read(ptr, len);
+    Position_ += ret;
+    return ret;
+}
+
+size_t TAlignedInput::DoSkip(size_t len) {
+    size_t ret = Stream_->Skip(len);
+    Position_ += ret;
+    return ret;
+}
+
+size_t TAlignedInput::DoReadTo(TString& st, char ch) {
+    size_t ret = Stream_->ReadTo(st, ch);
+    Position_ += ret;
+    return ret;
+}
+
+ui64 TAlignedInput::DoReadAll(IOutputStream& out) {
+    ui64 ret = Stream_->ReadAll(out);
+    Position_ += ret;
+    return ret;
+}
+
+void TAlignedOutput::DoWrite(const void* ptr, size_t len) {
+    Stream_->Write(ptr, len);
+    Position_ += len;
+}