From eb24c3baa48bff34fd984c43277ec51502b7b722 Mon Sep 17 00:00:00 2001 From: levlam Date: Mon, 29 Apr 2019 22:26:03 +0300 Subject: [PATCH] Return back formatting. GitOrigin-RevId: bf312eacf255e8bae70a60d31d5a4f62063814af --- tdactor/td/actor/impl/Scheduler.h | 47 +++++++++++++++---------------- 1 file changed, 22 insertions(+), 25 deletions(-) diff --git a/tdactor/td/actor/impl/Scheduler.h b/tdactor/td/actor/impl/Scheduler.h index f36ca8d48..fcb613c39 100644 --- a/tdactor/td/actor/impl/Scheduler.h +++ b/tdactor/td/actor/impl/Scheduler.h @@ -229,40 +229,37 @@ void Scheduler::send_impl(const ActorId<> &actor_id, const RunFuncT &run_func, c template void Scheduler::send_lambda(ActorRef actor_ref, EventT &&lambda) { - return send_impl( - actor_ref.get(), - [&](ActorInfo *actor_info) { - event_context_ptr_->link_token = actor_ref.token(); - lambda(); - }, - [&]() { - auto event = Event::lambda(std::forward(lambda)); - event.set_link_token(actor_ref.token()); - return std::move(event); - }); + return send_impl(actor_ref.get(), + [&](ActorInfo *actor_info) { + event_context_ptr_->link_token = actor_ref.token(); + lambda(); + }, + [&]() { + auto event = Event::lambda(std::forward(lambda)); + event.set_link_token(actor_ref.token()); + return std::move(event); + }); } template void Scheduler::send_closure(ActorRef actor_ref, EventT &&closure) { - return send_impl( - actor_ref.get(), - [&](ActorInfo *actor_info) { - event_context_ptr_->link_token = actor_ref.token(); - closure.run(static_cast(actor_info->get_actor_unsafe())); - }, - [&]() { - auto event = Event::immediate_closure(std::forward(closure)); - event.set_link_token(actor_ref.token()); - return std::move(event); - }); + return send_impl(actor_ref.get(), + [&](ActorInfo *actor_info) { + event_context_ptr_->link_token = actor_ref.token(); + closure.run(static_cast(actor_info->get_actor_unsafe())); + }, + [&]() { + auto event = Event::immediate_closure(std::forward(closure)); + event.set_link_token(actor_ref.token()); + return std::move(event); + }); } template void Scheduler::send(ActorRef actor_ref, Event &&event) { event.set_link_token(actor_ref.token()); - return send_impl( - actor_ref.get(), [&](ActorInfo *actor_info) { do_event(actor_info, std::move(event)); }, - [&]() { return std::move(event); }); + return send_impl(actor_ref.get(), [&](ActorInfo *actor_info) { do_event(actor_info, std::move(event)); }, + [&]() { return std::move(event); }); } inline void Scheduler::subscribe(PollableFd fd, PollFlags flags) {