Method SetUp

test/anyflow/test_data.cpp:28–60

struct DataTest : public ::testing::Test {
  virtual void SetUp() override {
    auto creator = [] {
      return ::std::unique_ptr<GraphProcessor>(new MockProcessor);
    };
    {
      auto& vertex = builder.add_vertex(creator);
      vertex.option(&mx);
      vertex.named_depend("a").to("A");
      vertex.named_emit("x").to("B");
    }
    {
      auto& vertex = builder.add_vertex(creator);
      vertex.option(&my);
      vertex.named_depend("a").to("B");
      vertex.named_emit("x").to("C");
    }
    {
      auto& vertex = builder.add_vertex([] {
        return ::std::unique_ptr<GraphProcessor>(new GraphProcessor);
      });
      vertex.anonymous_emit().to("D");
    }
    executor.initialize(4, 128);
    builder.set_executor(executor);
    ASSERT_EQ(0, builder.finish());
    graph = builder.build();
    ASSERT_TRUE(graph);

    a = graph->find_data("A");
    b = graph->find_data("B");
    c = graph->find_data("C");
    d = graph->find_data("D");
  }

  ThreadPoolGraphExecutor executor;
  GraphBuilder builder;