Method Pipe

src/QueryPipeline/Pipe.cpp:107–109

}

Pipe::Pipe() : processors(std::make_shared<Processors>())
{
}

Pipe::Pipe(ProcessorPtr source, OutputPort * output, OutputPort * totals, OutputPort * extremes)
    : processors(std::make_shared<Processors>())