2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
42#ifndef CORE_PIPE_PIPE_H
43#define CORE_PIPE_PIPE_H
50#ifndef DOXYGEN_SHOULD_SKIP_THIS
64 Pipe(
const std::function<
void(
PipeSource&,
PipeSink&)>& onSuccess,
const std::function<
void(
int)>& onError);
static void init(int argc, char *argv[])
static int start(const utils::Timeval &timeOut={LONG_MAX, 0})
void setOnError(const std::function< void(int)> &onError)
void setOnEof(const std::function< void()> &onEof)
void setOnData(const std::function< void(const char *, std::size_t)> &onData)
void send(const char *chunk, std::size_t chunkLen)
void send(const std::string &data)
void setOnError(const std::function< void(int)> &onError)
Pipe & operator=(const Pipe &pipe)=delete
Pipe(const Pipe &pipe)=delete
Pipe(const std::function< void(PipeSource &, PipeSink &)> &onSuccess, const std::function< void(int)> &onError)
int main(int argc, char *argv[])