@@ -13,7 +13,7 @@ MultiClient::MultiClient(MultiClientConfig config, std::unique_ptr<ResponseCallb
1313 scheduler_ (
1414 std::make_shared<td::actor::Scheduler>(std::vector<td::actor::Scheduler::NodeInfo>{config.scheduler_threads })
1515 ) {
16- scheduler_->run_in_context_external ([this , cb = std::move (callback)]() mutable {
16+ scheduler_->run_in_context ([this , cb = std::move (callback)]() mutable {
1717 client_ = td::actor::create_actor<MultiClientActor>(
1818 " multiclient" ,
1919 MultiClientActorConfig{
@@ -39,15 +39,15 @@ td::Result<std::string> MultiClient::send_request_json(RequestJson req) const {
3939 auto promise =
4040 td::Promise<std::string>([p = std::move (request_promise)](auto result) mutable { p.set_value (std::move (result)); });
4141
42- scheduler_->run_in_context_external ([this , p = std::move (promise), req = std::move (req)]() mutable {
42+ scheduler_->run_in_context ([this , p = std::move (promise), req = std::move (req)]() mutable {
4343 td::actor::send_closure (client_.get (), &MultiClientActor::send_request_json, std::move (req), std::move (p));
4444 });
4545
4646 return request_future.get ();
4747}
4848
4949void MultiClient::send_callback_request (RequestCallback req) const {
50- scheduler_->run_in_context_external ([this , req = std::move (req)]() mutable {
50+ scheduler_->run_in_context ([this , req = std::move (req)]() mutable {
5151 td::actor::send_closure (client_.get (), &MultiClientActor::send_callback_request, std::move (req));
5252 });
5353}
@@ -59,7 +59,7 @@ td::Result<std::int32_t> MultiClient::get_consensus_block() const {
5959 p.set_value (std::move (result));
6060 });
6161
62- scheduler_->run_in_context_external ([this , p = std::move (promise)]() mutable {
62+ scheduler_->run_in_context ([this , p = std::move (promise)]() mutable {
6363 td::actor::send_closure (client_.get (), &MultiClientActor::get_consensus_block, std::move (p));
6464 });
6565
@@ -72,7 +72,7 @@ td::Result<SessionPtr> MultiClient::get_session(const RequestParameters& params,
7272 auto promise =
7373 td::Promise<SessionPtr>([p = std::move (request_promise)](auto result) mutable { p.set_value (std::move (result)); });
7474
75- scheduler_->run_in_context_external ([this , params, session, p = std::move (promise)]() mutable {
75+ scheduler_->run_in_context ([this , params, session, p = std::move (promise)]() mutable {
7676 td::actor::send_closure (client_.get (), &MultiClientActor::get_session, params, std::move (session), std::move (p));
7777 });
7878
0 commit comments