library/cpp/yson_pull/detail/output/stream.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

#pragma once 
 
#include "buffered.h" 
 
#include <library/cpp/yson_pull/detail/macros.h>
#include <library/cpp/yson_pull/exceptions.h>
 
#include <util/stream/output.h> 
#include <util/stream/file.h> 
#include <util/system/file.h> 
 
namespace NYsonPull { 
    namespace NDetail { 
        namespace NOutput { 
            class TStream: public TBuffered<TStream> { 
                IOutputStream* Output;
 
            public: 
                TStream(IOutputStream* output, size_t buffer_size)
                    : TBuffered<TStream>(buffer_size) 
                    , Output(output) 
                { 
                } 
 
                void write(TStringBuf data) { 
                    Output->Write(data); 
                } 
            }; 
 
            template <typename TOutput>
            class TOwned: public TBuffered<TOwned<TOutput>> { 
                TOutput Output; 
 
            public: 
                template <typename... Args>
                TOwned(size_t buffer_size, Args&&... args) 
                    : TBuffered<TOwned>(buffer_size) 
                    , Output(std::forward<Args>(args)...) 
                { 
                } 
 
                void write(TStringBuf data) { 
                    Output.Write(data); 
                } 
            }; 
 
            class TFHandle: public TOwned<TUnbufferedFileOutput> {
            public: 
                TFHandle(int fd, size_t buffer_size) 
                    : TOwned<TUnbufferedFileOutput>(buffer_size, Duplicate(fd))
                { 
                } 
            }; 
        } 
    }     // namespace NDetail
}