testpipe.cpp File Reference

#include "core/SNodeC.h"
#include "core/pipe/Pipe.h"
#include "core/pipe/PipeSink.h"
#include "core/pipe/PipeSource.h"

Include dependency graph for testpipe.cpp:

Go to the source code of this file.

Functions
int	main (int argc, char *argv[])

Function Documentation

main()

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 57 of file testpipe.cpp.

                                 {
    core::SNodeC::init(argc, argv);
 
    const core::pipe::Pipe pipe(
        []([[maybe_unused]] core::pipe::PipeSource& pipeSource, [[maybe_unused]] core::pipe::PipeSink& pipeSink) {
            pipeSink.setOnData([&pipeSource](const char* chunk, std::size_t chunkLen) {
                const std::string string(chunk, chunkLen);
                VLOG(1) << "Pipe Data: " << string;
                pipeSource.send(chunk, chunkLen);
                // pipeSink.disable();
                // pipeSource.disable();
            });
 
            pipeSink.setOnEof([]() {
                VLOG(1) << "Pipe EOF";
            });
 
            pipeSink.setOnError([]([[maybe_unused]] int errnum) {
                VLOG(1) << "PipeSink";
            });
 
            pipeSource.setOnError([]([[maybe_unused]] int errnum) {
                VLOG(1) << "PipeSource";
            });
 
            pipeSource.send("Hello World!");
        },
        []([[maybe_unused]] int errnum) {
            PLOG(ERROR) << "Pipe not created";
        });
 
    return core::SNodeC::start();
}

References core::SNodeC::init(), core::pipe::Pipe::Pipe(), core::pipe::PipeSource::send(), core::pipe::PipeSource::send(), core::pipe::PipeSink::setOnData(), core::pipe::PipeSink::setOnEof(), core::pipe::PipeSink::setOnError(), core::pipe::PipeSource::setOnError(), and core::SNodeC::start().

Here is the call graph for this function: