Commit 58b281ec authored by Dominik Charousset's avatar Dominik Charousset

Add run_exhaustively_while convenience function

parent 2e704f7e
...@@ -578,6 +578,12 @@ struct test_coordinator_fixture { ...@@ -578,6 +578,12 @@ struct test_coordinator_fixture {
sched.run_dispatch_loop(streaming_cycle); sched.run_dispatch_loop(streaming_cycle);
} }
/// Dispatches messages and timeouts until no activity remains.
template <class Predicate>
void run_exhaustively_while(Predicate predicate) {
sched.run_dispatch_loop(predicate, streaming_cycle);
}
template <class T = int> template <class T = int>
caf::expected<T> fetch_result() { caf::expected<T> fetch_result() {
caf::expected<T> result = caf::error{}; caf::expected<T> result = caf::error{};
......
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