Method SetUp

test/anyflow/test_dependency.cpp:51–100

struct DependencyTest : public ::testing::Test {
  virtual void SetUp() override {
    {
      auto& vertex = builder.add_vertex([] {
        return ::std::unique_ptr<ConstProcessor>(new ConstProcessor);
      });
      vertex.named_depend("a").to("A").on("C1");
      vertex.named_emit("x").to("X");
    }
    {
      auto& vertex = builder.add_vertex([] {
        return ::std::unique_ptr<ConstProcessor>(new ConstProcessor);
      });
      vertex.named_depend("a").to("A").on("C2");
      vertex.named_emit("x").to("Y");
    }
    {
      auto& vertex = builder.add_vertex([] {
        return ::std::unique_ptr<MutableProcessor>(new MutableProcessor);
      });
      vertex.named_depend("a").to("A").on("C3");
      vertex.named_emit("x").to("Z");
    }
    {
      auto& vertex = builder.add_vertex([] {
        return ::std::unique_ptr<VariableProcessor>(new VariableProcessor);
      });
      for (size_t index = 0; index < v.size(); index++) {
        vertex.anonymous_depend().to(v[index]).on("C4");
      }
      for (size_t index = 0; index < rv.size(); index++) {
        vertex.anonymous_emit().to(rv[index]);
      }
    }
    builder.finish();
    graph = builder.build();
    a = graph->find_data("A");
    x = graph->find_data("X");
    y = graph->find_data("Y");
    z = graph->find_data("Z");
    for (size_t index = 0; index < v.size(); index++) {
      gv.emplace_back(graph->find_data(v[index]));
    }
    for (size_t index = 0; index < rv.size(); index++) {
      grv.emplace_back(graph->find_data(rv[index]));
    }
    c1 = graph->find_data("C1");
    c2 = graph->find_data("C2");
    c3 = graph->find_data("C3");
    c4 = graph->find_data("C4");
  }

  GraphBuilder builder;
  ::std::unique_ptr<Graph> graph;