aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/blockcodecs/core/stream.h
diff options
context:
space:
mode:
authorAnton Samokhvalov <pg83@yandex.ru>2022-02-10 16:45:17 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:17 +0300
commitd3a398281c6fd1d3672036cb2d63f842d2cb28c5 (patch)
treedd4bd3ca0f36b817e96812825ffaf10d645803f2 /library/cpp/blockcodecs/core/stream.h
parent72cb13b4aff9bc9cf22e49251bc8fd143f82538f (diff)
downloadydb-d3a398281c6fd1d3672036cb2d63f842d2cb28c5.tar.gz
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/blockcodecs/core/stream.h')
-rw-r--r--library/cpp/blockcodecs/core/stream.h66
1 files changed, 33 insertions, 33 deletions
diff --git a/library/cpp/blockcodecs/core/stream.h b/library/cpp/blockcodecs/core/stream.h
index b0d7929f05..fd44ef88f2 100644
--- a/library/cpp/blockcodecs/core/stream.h
+++ b/library/cpp/blockcodecs/core/stream.h
@@ -1,46 +1,46 @@
-#pragma once
-
-#include <util/stream/walk.h>
-#include <util/stream/input.h>
-#include <util/stream/output.h>
-#include <util/stream/zerocopy.h>
-#include <util/generic/buffer.h>
-
-namespace NBlockCodecs {
+#pragma once
+
+#include <util/stream/walk.h>
+#include <util/stream/input.h>
+#include <util/stream/output.h>
+#include <util/stream/zerocopy.h>
+#include <util/generic/buffer.h>
+
+namespace NBlockCodecs {
struct ICodec;
-
+
class TCodedOutput: public IOutputStream {
- public:
+ public:
TCodedOutput(IOutputStream* out, const ICodec* c, size_t bufLen);
~TCodedOutput() override;
-
- private:
+
+ private:
void DoWrite(const void* buf, size_t len) override;
void DoFlush() override;
void DoFinish() override;
-
- bool FlushImpl();
-
- private:
- const ICodec* C_;
- TBuffer D_;
- TBuffer O_;
+
+ bool FlushImpl();
+
+ private:
+ const ICodec* C_;
+ TBuffer D_;
+ TBuffer O_;
IOutputStream* S_;
- };
-
+ };
+
class TDecodedInput: public IWalkInput {
- public:
+ public:
TDecodedInput(IInputStream* in);
- TDecodedInput(IInputStream* in, const ICodec* codec);
-
+ TDecodedInput(IInputStream* in, const ICodec* codec);
+
~TDecodedInput() override;
-
- private:
+
+ private:
size_t DoUnboundedNext(const void** ptr) override;
-
- private:
- TBuffer D_;
+
+ private:
+ TBuffer D_;
IInputStream* S_;
- const ICodec* C_;
- };
-}
+ const ICodec* C_;
+ };
+}