Method SetUp

test/anyflow/test_processor.cpp:770–784

struct ProcessorRunTest : public ::testing::Test {
  virtual void SetUp() override {
    {
      auto& vertex = builder.add_vertex([] {
        return ::std::unique_ptr<GraphProcessor>(new HookedProcessor);
      });
      vertex.option(&control);
      vertex.named_emit("x").to("A");
    }
    executor.initialize(4, 128);
    builder.set_executor(executor);
    builder.finish();
    graph = builder.build();
    a = graph->find_data("A");
    p = control.processor;
  }

  ThreadPoolGraphExecutor executor;
  GraphBuilder builder;