in dispenso/detail/pipeline_impl.h [218:224]
void execute(Input&& input) {
this->tasks_.schedule([input = std::move(input), this](auto&& stageCompleteFunc) mutable {
auto&& res = this->stage_(std::move(input));
stageCompleteFunc();
this->pipeNext_.execute(res);
});
}