Commit c1792e49 authored by Dominik Charousset's avatar Dominik Charousset

Fix pipeline_streaming messaging checks

parent 178aba7e
......@@ -310,8 +310,9 @@ CAF_TEST(depth_2_pipeline_500_items) {
}
MESSAGE("trigger timeouts");
tick();
allow((action), from(snk).to(snk));
allow((action), from(src).to(src));
while (allow((action), to(snk)) || allow((action), to(src))) {
// repeat
}
MESSAGE("process ack_batch in source");
expect((upstream_msg::ack_batch), from(snk).to(src));
} while (!received<downstream_msg::close>(snk));
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment