1 files changed, 10 insertions, 20 deletions
diff --git a/tdactor/test/actors_simple.cpp b/tdactor/test/actors_simple.cpp
index 58f14ac48..78d32d543 100644
--- a/tdactor/test/actors_simple.cpp
+++ b/tdactor/test/actors_simple.cpp
@@ -256,8 +256,7 @@ TEST(Actors, simple_migrate) {
   sb.clear();
   sb2.clear();
 
-  td::ConcurrentScheduler scheduler;
-  scheduler.init(2);
+  td::ConcurrentScheduler scheduler(2, 0);
   auto pong = scheduler.create_actor_unsafe<Pong>(2, "Pong").release();
   scheduler.create_actor_unsafe<Ping>(1, "Ping", pong).release();
   scheduler.start();
@@ -300,8 +299,7 @@ class OpenClose final : public td::Actor {
 };
 
 TEST(Actors, open_close) {
-  td::ConcurrentScheduler scheduler;
-  scheduler.init(2);
+  td::ConcurrentScheduler scheduler(2, 0);
   int cnt = 10000;  // TODO(perf) optimize
   scheduler.create_actor_unsafe<OpenClose>(1, "A", cnt).release();
   scheduler.create_actor_unsafe<OpenClose>(2, "B", cnt).release();
@@ -425,8 +423,7 @@ class LinkTokenMasterActor final : public td::Actor {
 };
 
 TEST(Actors, link_token) {
-  td::ConcurrentScheduler scheduler;
-  scheduler.init(0);
+  td::ConcurrentScheduler scheduler(0, 0);
   auto cnt = 100000;
   scheduler.create_actor_unsafe<LinkTokenMasterActor>(0, "A", cnt).release();
   scheduler.start();
@@ -485,8 +482,7 @@ class LaterMasterActor final : public td::Actor {
 
 TEST(Actors, later) {
   sb.clear();
-  td::ConcurrentScheduler scheduler;
-  scheduler.init(0);
+  td::ConcurrentScheduler scheduler(0, 0);
   scheduler.create_actor_unsafe<LaterMasterActor>(0, "A").release();
   scheduler.start();
   while (scheduler.run_main(10)) {
@@ -524,8 +520,7 @@ class MultiPromise1 final : public td::Actor {
 };
 
 TEST(Actors, MultiPromise) {
-  td::ConcurrentScheduler scheduler;
-  scheduler.init(0);
+  td::ConcurrentScheduler scheduler(0, 0);
   scheduler.create_actor_unsafe<MultiPromise1>(0, "A").release();
   scheduler.start();
   while (scheduler.run_main(10)) {
@@ -546,8 +541,7 @@ class FastPromise final : public td::Actor {
 };
 
 TEST(Actors, FastPromise) {
-  td::ConcurrentScheduler scheduler;
-  scheduler.init(0);
+  td::ConcurrentScheduler scheduler(0, 0);
   scheduler.create_actor_unsafe<FastPromise>(0, "A").release();
   scheduler.start();
   while (scheduler.run_main(10)) {
@@ -566,8 +560,7 @@ class StopInTeardown final : public td::Actor {
 };
 
 TEST(Actors, stop_in_teardown) {
-  td::ConcurrentScheduler scheduler;
-  scheduler.init(0);
+  td::ConcurrentScheduler scheduler(0, 0);
   scheduler.create_actor_unsafe<StopInTeardown>(0, "A").release();
   scheduler.start();
   while (scheduler.run_main(10)) {
@@ -601,8 +594,7 @@ class AlwaysWaitForMailbox final : public td::Actor {
 };
 
 TEST(Actors, always_wait_for_mailbox) {
-  td::ConcurrentScheduler scheduler;
-  scheduler.init(0);
+  td::ConcurrentScheduler scheduler(0, 0);
   scheduler.create_actor_unsafe<AlwaysWaitForMailbox>(0, "A").release();
   scheduler.start();
   while (scheduler.run_main(10)) {
@@ -612,8 +604,7 @@ TEST(Actors, always_wait_for_mailbox) {
 
 #if !TD_THREAD_UNSUPPORTED && !TD_EVENTFD_UNSUPPORTED
 TEST(Actors, send_from_other_threads) {
-  td::ConcurrentScheduler scheduler;
-  scheduler.init(1);
+  td::ConcurrentScheduler scheduler(1, 0);
   int thread_n = 10;
   class Listener final : public td::Actor {
    public:
@@ -680,8 +671,7 @@ class MultiPromiseSendClosureLaterTest final : public td::Actor {
 };
 
 TEST(Actors, MultiPromiseSendClosureLater) {
-  td::ConcurrentScheduler scheduler;
-  scheduler.init(0);
+  td::ConcurrentScheduler scheduler(0, 0);
   scheduler.create_actor_unsafe<MultiPromiseSendClosureLaterTest>(0, "MultiPromiseSendClosureLaterTest").release();
   scheduler.start();
   while (scheduler.run_main(1)) {