GitOrigin-RevId: 762719f8093a862b93bd77c1e8e28d7feb4486e0
This commit is contained in:
levlam 2018-09-14 23:03:26 +03:00
parent 47bf1bf060
commit 5dfeb9adf4

View File

@ -173,7 +173,7 @@ class Client::Impl final {
td_ = concurrent_scheduler_->create_actor_unsafe<Td>(0, "Td", std::make_unique<Callback>(output_queue_)); td_ = concurrent_scheduler_->create_actor_unsafe<Td>(0, "Td", std::make_unique<Callback>(output_queue_));
concurrent_scheduler_->start(); concurrent_scheduler_->start();
scheduler_thread_ = thread([scheduler = concurrent_scheduler_] { scheduler_thread_ = thread([concurrent_scheduler = concurrent_scheduler_] {
while (concurrent_scheduler->run_main(10)) { while (concurrent_scheduler->run_main(10)) {
} }
concurrent_scheduler->finish(); concurrent_scheduler->finish();