| 236 | */ |
| 237 | |
| 238 | TEST_F(DataTest, closure_finish_when_data_ready) { |
| 239 | *a->emit<::std::string>() = "10086"; |
| 240 | // mx.lock(); |
| 241 | auto closure = graph->run(b); |
| 242 | ::usleep(100000); |
| 243 | // ASSERT_FALSE(closure.finished()); |
| 244 | // mx.unlock(); |
| 245 | ASSERT_EQ(0, closure.get()); |
| 246 | } |
| 247 | |
| 248 | /* |
| 249 | TEST_F(DataTest, activate_data_fail_for_no_producer) { |