| 5 | |
| 6 | class Parse : public ::babylon::anyflow::GraphProcessor { |
| 7 | virtual int process() noexcept override { |
| 8 | user_id = request->user_id(); |
| 9 | // Use ref to make it zero copy |
| 10 | query.emit().ref(request->query()); |
| 11 | return 0; |
| 12 | } |
| 13 | |
| 14 | // clang-format off |
| 15 | ANYFLOW_INTERFACE( |