Function TEST_F

test/anyflow/test_closure.cpp:77–90

};

TEST_F(ClosureTest, finish_when_data_ready) {
  a->emit<int>();
  auto closure = graph->run(b);
  ::std::thread([&] {
    ::usleep(100000);
    begin.set_value(true);
    end.set_value(0);
  }).detach();
  ASSERT_FALSE(closure.finished());
  ASSERT_EQ(0, closure.get());
  ASSERT_TRUE(closure.finished());
  ASSERT_EQ(0, closure.error_code());
  ASSERT_EQ("10086", *b->value<std::string>());
}

TEST_F(ClosureTest, finish_when_error_occur) {
  a->emit<int>();