Method process

test/anyflow/test_processor.cpp:359–363

TEST_F(ProcessorTest, downstream_function_run_before_current_one_return) {
  struct F1 : public GraphProcessor {
    virtual int process() noexcept override {
      *x.emit() = *a;
      f.get();
      return 0;
    }
    ANYFLOW_INTERFACE(ANYFLOW_DEPEND_DATA(int32_t, a)
                          ANYFLOW_EMIT_DATA(int32_t, x))
    ::std::promise<void> p;