Method SetUp

test/anyflow/test_channel.cpp:85–152

struct ChannelTest : public ::testing::Test {
  virtual void SetUp() override {
    executor.initialize(4, 128);
    builder.set_executor(executor);
    {
      auto& vertex = builder.add_vertex([] {
        return ::std::unique_ptr<ChannelOutputProcessor>(
            new ChannelOutputProcessor);
      });
      vertex.named_emit("x").to("A");
    }
    {
      auto& vertex = builder.add_vertex([] {
        return ::std::unique_ptr<ChannelInputProcessor>(
            new ChannelInputProcessor);
      });
      vertex.named_depend("a").to("A");
      vertex.named_emit("done").to("B");
    }
    {
      auto& vertex = builder.add_vertex([] {
        return ::std::unique_ptr<ChannelOutputProcessor>(
            new ChannelOutputProcessor);
      });
      vertex.named_emit("x").to("MA");
    }
    {
      auto& vertex = builder.add_vertex([] {
        return ::std::unique_ptr<MutableChannelInputProcessor>(
            new MutableChannelInputProcessor);
      });
      vertex.named_depend("a").to("MA");
      vertex.named_emit("done").to("C");
    }
    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");

    ChannelOutputProcessor::enter_promise =
        ::std::promise<OutputChannel<::std::string>>();
    ChannelOutputProcessor::enter_future =
        ChannelOutputProcessor::enter_promise.get_future();

    ChannelOutputProcessor::leave_promise = ::std::promise<void>();
    ChannelOutputProcessor::leave_future =
        ChannelOutputProcessor::leave_promise.get_future();

    ChannelInputProcessor::enter_promise =
        ::std::promise<ChannelConsumer<::std::string>>();
    ChannelInputProcessor::enter_future =
        ChannelInputProcessor::enter_promise.get_future();

    ChannelInputProcessor::leave_promise = ::std::promise<void>();
    ChannelInputProcessor::leave_future =
        ChannelInputProcessor::leave_promise.get_future();