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
commit8d3a5b9c70bfb823a30242286328d6017b82b9ce (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /util/stream/pipe.h
parent1c01ed5294724fda060c1f0bd674b315fe249598 (diff)
downloadydb-8d3a5b9c70bfb823a30242286328d6017b82b9ce.tar.gz
Restoring authorship annotation for <ekrokhalev@yandex-team.ru>. Commit 2 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 7ef5766e6e..18525b9517 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;
-};
-
+};
+
/** @} */