MCPcopy Create free account
hub / github.com/AlexInLog/ReactivePlusPlus / drain

Function drain

src/tests/rppasio/test_rppasio_scheduler.cpp:33–39  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

31namespace
32{
33 void drain(const auto& disposable, asio::io_context& context)
34 {
35 while (!disposable.is_disposed())
36 {
37 context.run_one();
38 }
39 }
40} // namespace
41
42TEST_CASE("strand shares current_thread queue")

Callers 1

Calls 1

is_disposedMethod · 0.45

Tested by

no test coverage detected