void execute()

in dispenso/detail/pipeline_impl.h [236:244]

• 9 lines of code
• 4 McCabe index (conditional complexity)

  void execute(Input&& input) {
    this->tasks_.schedule([input = std::move(input), this](auto&& stageCompleteFunc) mutable {
      auto op = this->stage_(std::move(input));
      stageCompleteFunc();
      if (op) {
        this->pipeNext_.execute(std::move(op.value()));
      }
    });
  }