Gets a functor that runs the operator. */
| 42 | public: |
| 43 | /** Gets a functor that runs the operator. */ |
| 44 | auto GetRunnable() && { |
| 45 | assert(!node_->is_pipeline_output); |
| 46 | return [self = std::move(*this)](tasking::Task *t) mutable { |
| 47 | self.task_ = t; |
| 48 | return self.Run(); |
| 49 | }; |
| 50 | } |
| 51 | |
| 52 | private: |
| 53 | /** Returns the stream in which the output is consumed if the consumers work on the same stream. |