Gets a functor that returns an output Workspace compatible with DALI pipeline. */
| 492 | /** Gets a functor that returns an output Workspace compatible with DALI pipeline. |
| 493 | */ |
| 494 | auto GetRunnable() && { |
| 495 | assert(node_->is_pipeline_output); |
| 496 | return [self = std::move(*this)](tasking::Task *t) mutable { |
| 497 | self.task_ = t; |
| 498 | return self.Run(); |
| 499 | }; |
| 500 | } |
| 501 | private: |
| 502 | friend class ExecNodeTask; |
| 503 | using ExecNodeTask::ExecNodeTask; |