diff --git a/tests/db/run_loop_tests.cpp b/tests/db/run_loop_tests.cpp index b189d00e..c19aa760 100644 --- a/tests/db/run_loop_tests.cpp +++ b/tests/db/run_loop_tests.cpp @@ -39,7 +39,7 @@ inline void run_until(uv_loop_t *loop, std::function predicate) { uv_idle_stop(observer.idle); } -TEST_CASE("run loops", "[run loops]") { +TEST_CASE("user defined uv_loop", "[scheduler]") { realm_path path; SECTION("threads detached", "[run loops]") { @@ -78,7 +78,11 @@ TEST_CASE("run loops", "[run loops]") { managed_obj.str_col = "456"; }); - uv_run(loop, UV_RUN_DEFAULT); + run_until(loop, [&]() { + return signal1; + }); + uv_loop_close(loop); + free(loop); }).detach(); } @@ -118,7 +122,11 @@ TEST_CASE("run loops", "[run loops]") { }); } - uv_run(loop, UV_RUN_DEFAULT); + run_until(loop, [&]() { + return signal2; + }); + uv_loop_close(loop); + free(loop); }).detach(); } @@ -157,6 +165,8 @@ TEST_CASE("run loops", "[run loops]") { }); t1.unregister(); + uv_loop_close(loop); + free(loop); } }