| 13 | |
| 14 | struct DummyProcessor : public GraphProcessor { |
| 15 | virtual int process() noexcept override { |
| 16 | auto do_process = begin.get(); |
| 17 | begun.set_value(); |
| 18 | if (do_process) { |
| 19 | *x.emit() = "10086"; |
| 20 | } |
| 21 | auto ret = end.get(); |
| 22 | ended.set_value(); |
| 23 | return ret; |
| 24 | } |
| 25 | |
| 26 | ANYFLOW_INTERFACE(ANYFLOW_EMIT_DATA(::std::string, x)) |
| 27 |