aboutsummaryrefslogtreecommitdiffstats
path: root/util/stream/pipe.h
diff options
context:
space:
mode:
authorekrokhalev <ekrokhalev@yandex-team.ru>2022-02-10 16:50:10 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:10 +0300
commit1c01ed5294724fda060c1f0bd674b315fe249598 (patch)
treec21292982d2c8182cdf5753f9a49e7cda547f4d3 /util/stream/pipe.h
parent9991a6195dee8db26aa7e2f5f21549fb20e25002 (diff)
downloadydb-1c01ed5294724fda060c1f0bd674b315fe249598.tar.gz
Restoring authorship annotation for <ekrokhalev@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/stream/pipe.h')
-rw-r--r--util/stream/pipe.h18
1 files changed, 9 insertions, 9 deletions
diff --git a/util/stream/pipe.h b/util/stream/pipe.h
index 18525b9517..7ef5766e6e 100644
--- a/util/stream/pipe.h
+++ b/util/stream/pipe.h
@@ -76,15 +76,15 @@ private:
void DoWrite(const void* buf, size_t len) override;
};
-class TPipedBase {
+class TPipedBase {
protected:
TPipedBase(PIPEHANDLE fd);
virtual ~TPipedBase();
protected:
TPipeHandle Handle_;
-};
-
+};
+
/**
* Input stream that binds to a standard output stream of an existing process.
*/
@@ -92,11 +92,11 @@ class TPipedInput: public TPipedBase, public IInputStream {
public:
TPipedInput(PIPEHANDLE fd);
~TPipedInput() override;
-
+
private:
size_t DoRead(void* buf, size_t len) override;
-};
-
+};
+
/**
* Output stream that binds to a standard input stream of an existing process.
*/
@@ -104,9 +104,9 @@ class TPipedOutput: public TPipedBase, public IOutputStream {
public:
TPipedOutput(PIPEHANDLE fd);
~TPipedOutput() override;
-
+
private:
void DoWrite(const void* buf, size_t len) override;
-};
-
+};
+
/** @} */