| 466 | |
| 467 | TEST_F(ProcessorTest, depend_essential) { |
| 468 | struct F : public GraphProcessor { |
| 469 | virtual int process() noexcept override { |
| 470 | if (a) { |
| 471 | *x.emit() = 1; |
| 472 | } else { |
| 473 | *x.emit() = 0; |
| 474 | } |
| 475 | return 0; |
| 476 | } |
| 477 | ANYFLOW_INTERFACE(ANYFLOW_DEPEND_DATA(int, a, 0) // essential = 0 |
| 478 | ANYFLOW_EMIT_DATA(int, x)) |
| 479 | }; |
| 480 | // depend A |
| 481 | auto& v1 = builder.add_vertex([] { |
| 482 | return ::std::unique_ptr<F>(new F); |